org.locationtech.geowave.datastore.kudu.operations

Class KuduRangeRead<T>

java.lang.Object

org.locationtech.geowave.datastore.kudu.operations.KuduRangeRead<T>

public class KuduRangeRead<T>
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	KuduRangeRead(Collection<SinglePartitionQueryRanges> ranges, short[] adapterIds, org.apache.kudu.client.KuduTable table, KuduOperations operations, boolean visibilityEnabled, java.util.function.Predicate<GeoWaveRow> filter, GeoWaveRowIteratorTransformer<T> rowTransformer, boolean rowMerging)

Method Summary

Modifier and Type	Method and Description
void	checkFinalize(org.apache.kudu.client.AsyncKuduScanner scanner, Semaphore semaphore, BlockingQueue<Object> resultQueue, AtomicInteger queryCount)
CloseableIterator<T>	executeQueryAsync(List<org.apache.kudu.client.AsyncKuduScanner> scanners)
com.stumbleupon.async.Deferred<Object>	executeScanner(org.apache.kudu.client.AsyncKuduScanner scanner, Semaphore semaphore, BlockingQueue<Object> resultQueue, AtomicInteger queryCount, AtomicBoolean isCanceled, boolean visibilityEnabled, java.util.function.Predicate<GeoWaveRow> filter, GeoWaveRowIteratorTransformer<T> rowTransformer, boolean rowMerging)
CloseableIterator<T>	results()

Methods inherited from class java.lang.Object

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

Constructor Detail

KuduRangeRead

protected KuduRangeRead(Collection<SinglePartitionQueryRanges> ranges,
                        short[] adapterIds,
                        org.apache.kudu.client.KuduTable table,
                        KuduOperations operations,
                        boolean visibilityEnabled,
                        java.util.function.Predicate<GeoWaveRow> filter,
                        GeoWaveRowIteratorTransformer<T> rowTransformer,
                        boolean rowMerging)

Method Detail

results

public CloseableIterator<T> results()

executeQueryAsync

public CloseableIterator<T> executeQueryAsync(List<org.apache.kudu.client.AsyncKuduScanner> scanners)

checkFinalize

public void checkFinalize(org.apache.kudu.client.AsyncKuduScanner scanner,
                          Semaphore semaphore,
                          BlockingQueue<Object> resultQueue,
                          AtomicInteger queryCount)

executeScanner

public com.stumbleupon.async.Deferred<Object> executeScanner(org.apache.kudu.client.AsyncKuduScanner scanner,
                                                             Semaphore semaphore,
                                                             BlockingQueue<Object> resultQueue,
                                                             AtomicInteger queryCount,
                                                             AtomicBoolean isCanceled,
                                                             boolean visibilityEnabled,
                                                             java.util.function.Predicate<GeoWaveRow> filter,
                                                             GeoWaveRowIteratorTransformer<T> rowTransformer,
                                                             boolean rowMerging)