io.druid.query.groupby

Class GroupByQueryHelper

java.lang.Object

io.druid.query.groupby.GroupByQueryHelper

public class GroupByQueryHelper
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	CTX_KEY_SORT_RESULTS

Constructor Summary

Constructors

Constructor and Description
GroupByQueryHelper()

Method Summary

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".

Methods inherited from class java.lang.Object

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

Field Detail

CTX_KEY_SORT_RESULTS

public static final String CTX_KEY_SORT_RESULTS

See Also:

Constant Field Values

Constructor Detail

GroupByQueryHelper

public GroupByQueryHelper()

Method Detail

createIndexAccumulatorPair

public static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> createIndexAccumulatorPair(GroupByQuery query,
                                                                                                    GroupByQueryConfig config,
                                                                                                    NonBlockingPool<ByteBuffer> bufferPool,
                                                                                                    boolean combine)

createBySegmentAccumulatorPair

public static <T> Pair<Queue,Accumulator<Queue,T>> createBySegmentAccumulatorPair()

makeIncrementalIndex

public static IncrementalIndex makeIncrementalIndex(GroupByQuery query,
                                                    GroupByQueryConfig config,
                                                    NonBlockingPool<ByteBuffer> bufferPool,
                                                    Sequence<Row> rows,
                                                    boolean combine)

postAggregate

public static Sequence<Row> postAggregate(GroupByQuery query,
                                          IncrementalIndex index)

rowSignatureFor

public static Map<String,ValueType> rowSignatureFor(GroupByQuery query)

Returns types for fields that will appear in the Rows output from "query". Useful for feeding them into RowBasedColumnSelectorFactory.

Parameters:

query - groupBy query

Returns:

row types