org.locationtech.geowave.datastore.redis.operations

Class BatchedRangeRead<T>

java.lang.Object

org.locationtech.geowave.datastore.redis.operations.BatchedRangeRead<T>

public class BatchedRangeRead<T>
extends Object

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

BatchedRangeRead(org.redisson.api.RedissonClient client, RedisOptions.Compression compression, String setNamePrefix, short adapterId, Collection<SinglePartitionQueryRanges> ranges, GeoWaveRowIteratorTransformer<T> rowTransformer, java.util.function.Predicate<GeoWaveRow> filter, boolean rowMerging, boolean async, org.apache.commons.lang3.tuple.Pair<Boolean,Boolean> groupByRowAndSortByTimePair, boolean isSortFinalResultsBySortKey, boolean visibilityEnabled)

Method Summary

Modifier and Type	Method and Description
CloseableIterator<T>	results()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchedRangeRead

protected BatchedRangeRead(org.redisson.api.RedissonClient client,
                           RedisOptions.Compression compression,
                           String setNamePrefix,
                           short adapterId,
                           Collection<SinglePartitionQueryRanges> ranges,
                           GeoWaveRowIteratorTransformer<T> rowTransformer,
                           java.util.function.Predicate<GeoWaveRow> filter,
                           boolean rowMerging,
                           boolean async,
                           org.apache.commons.lang3.tuple.Pair<Boolean,Boolean> groupByRowAndSortByTimePair,
                           boolean isSortFinalResultsBySortKey,
                           boolean visibilityEnabled)

Method Detail

results

public CloseableIterator<T> results()