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, StupidPool<ByteBuffer> bufferPool, boolean combine)
static IncrementalIndex	makeIncrementalIndex(GroupByQuery query, GroupByQueryConfig config, StupidPool<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".
static ResourceLimitExceededException	throwAccumulationResourceLimitExceededException() Throw a ResourceLimitExceededException.

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,
                                                                                                    StupidPool<ByteBuffer> bufferPool,
                                                                                                    boolean combine)

createBySegmentAccumulatorPair

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

makeIncrementalIndex

public static IncrementalIndex makeIncrementalIndex(GroupByQuery query,
                                                    GroupByQueryConfig config,
                                                    StupidPool<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

throwAccumulationResourceLimitExceededException

public static ResourceLimitExceededException throwAccumulationResourceLimitExceededException()

Throw a ResourceLimitExceededException. Only used by groupBy v2 when accumulation resources are exceeded, triggered by false return from Grouper.aggregate(Object).

Returns:

nothing will ever be returned; this return type is for your convenience, similar to Throwables.propagate in Guava.