Package | Description |
---|---|
io.druid.java.util.common | |
io.druid.query.groupby.epinephelinae | |
io.druid.query.scan | |
io.druid.segment |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterators.concat(List<? extends CloseableIterator<? extends T>> iterators) |
static <T> CloseableIterator<T> |
CloseableIterators.mergeSorted(List<? extends CloseableIterator<? extends T>> iterators,
Comparator<T> comparator) |
static <T> CloseableIterator<T> |
CloseableIterators.withEmptyBaggage(Iterator<T> innerIterator) |
static <T> CloseableIterator<T> |
CloseableIterators.wrap(Iterator<T> innerIterator,
Closeable closeable) |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterators.concat(List<? extends CloseableIterator<? extends T>> iterators) |
static <T> CloseableIterator<T> |
CloseableIterators.mergeSorted(List<? extends CloseableIterator<? extends T>> iterators,
Comparator<T> comparator) |
Modifier and Type | Class and Description |
---|---|
class |
CloseableGrouperIterator<KeyType,T> |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Grouper.Entry<KeyType>> |
ParallelCombiner.combine(List<? extends CloseableIterator<Grouper.Entry<KeyType>>> sortedIterators,
List<String> mergedDictionary)
Build a combining tree for the input iterators which combine input entries asynchronously.
|
CloseableIterator<Grouper.Entry<KeyType>> |
StreamingMergeSortedGrouper.iterator()
Return a sorted iterator.
|
CloseableIterator<Grouper.Entry<KeyType>> |
StreamingMergeSortedGrouper.iterator(boolean sorted)
Return a sorted iterator.
|
CloseableIterator<Grouper.Entry<KeyType>> |
SpillingGrouper.iterator(boolean sorted) |
CloseableIterator<Grouper.Entry<KeyType>> |
LimitedBufferHashGrouper.iterator(boolean sorted) |
CloseableIterator<Grouper.Entry<KeyType>> |
Grouper.iterator(boolean sorted)
Iterate through entries.
|
CloseableIterator<Grouper.Entry<KeyType>> |
ConcurrentGrouper.iterator(boolean sorted) |
CloseableIterator<Grouper.Entry<KeyType>> |
BufferHashGrouper.iterator(boolean sorted) |
CloseableIterator<Grouper.Entry<Integer>> |
BufferArrayGrouper.iterator(boolean sorted) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Grouper.Entry<KeyType>> |
ParallelCombiner.combine(List<? extends CloseableIterator<Grouper.Entry<KeyType>>> sortedIterators,
List<String> mergedDictionary)
Build a combining tree for the input iterators which combine input entries asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
ScanQueryLimitRowIterator |
Modifier and Type | Class and Description |
---|---|
static class |
IndexMerger.DictionaryMergeIterator |
Copyright © 2011–2018. All rights reserved.