public class GroupByQueryHelper extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CTX_KEY_SORT_RESULTS |
Constructor and Description |
---|
GroupByQueryHelper() |
Modifier and Type | Method and Description |
---|---|
static <T> Pair<Queue,Accumulator<Queue,T>> |
createBySegmentAccumulatorPair() |
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> |
createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
boolean combine) |
static IncrementalIndex |
makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
static Sequence<Row> |
postAggregate(GroupByQuery query,
IncrementalIndex index) |
static Map<String,ValueType> |
rowSignatureFor(GroupByQuery query)
Returns types for fields that will appear in the Rows output from "query".
|
public static final String CTX_KEY_SORT_RESULTS
public static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> createIndexAccumulatorPair(GroupByQuery query, GroupByQueryConfig config, NonBlockingPool<ByteBuffer> bufferPool, boolean combine)
public static <T> Pair<Queue,Accumulator<Queue,T>> createBySegmentAccumulatorPair()
public static IncrementalIndex makeIncrementalIndex(GroupByQuery query, GroupByQueryConfig config, NonBlockingPool<ByteBuffer> bufferPool, Sequence<Row> rows, boolean combine)
public static Sequence<Row> postAggregate(GroupByQuery query, IncrementalIndex index)
public static Map<String,ValueType> rowSignatureFor(GroupByQuery query)
RowBasedColumnSelectorFactory
.query
- groupBy queryCopyright © 2011–2018. All rights reserved.