public static class StorageProxy.RangeCommandIterator extends AbstractIterator<RowIterator> implements PartitionIterator
| Constructor and Description |
|---|
RangeCommandIterator(java.util.Iterator<StorageProxy.RangeForQuery> ranges,
PartitionRangeReadCommand command,
int concurrencyFactor,
int maxConcurrencyFactor,
int totalRangeCount,
Keyspace keyspace,
ConsistencyLevel consistency,
long queryStartNanoTime) |
| Modifier and Type | Method and Description |
|---|---|
int |
batchesRequested() |
void |
close() |
static int |
computeConcurrencyFactor(int totalRangeCount,
int rangesQueried,
int maxConcurrencyFactor,
int limit,
int liveReturned) |
RowIterator |
computeNext() |
int |
rangesQueried() |
endOfData, hasNext, next, peek, removepublic RangeCommandIterator(java.util.Iterator<StorageProxy.RangeForQuery> ranges, PartitionRangeReadCommand command, int concurrencyFactor, int maxConcurrencyFactor, int totalRangeCount, Keyspace keyspace, ConsistencyLevel consistency, long queryStartNanoTime)
public RowIterator computeNext()
computeNext in class AbstractIterator<RowIterator>public static int computeConcurrencyFactor(int totalRangeCount,
int rangesQueried,
int maxConcurrencyFactor,
int limit,
int liveReturned)
public void close()
close in interface java.lang.AutoCloseableclose in interface BasePartitionIterator<RowIterator>close in interface CloseableIterator<RowIterator>public int rangesQueried()
public int batchesRequested()
Copyright © 2009-2022 The Apache Software Foundation