Package | Description |
---|---|
io.druid.query.groupby.epinephelinae |
Modifier and Type | Method and Description |
---|---|
protected Grouper.Entry<KeyType> |
AbstractBufferHashGrouper.bucketEntryForOffset(int bucketOffset) |
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) |
Comparator<Grouper.Entry<T>> |
Grouper.KeySerdeFactory.objectComparator(boolean forceDefaultOrder)
Return an object that knows how to compare two serialized key instances.
|
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.
|
Constructor and Description |
---|
CloseableGrouperIterator(Grouper<KeyType> grouper,
boolean sorted,
Function<Grouper.Entry<KeyType>,T> transformer,
Closeable closeable) |
Copyright © 2011–2018. All rights reserved.