io.druid.query.groupby.epinephelinae

Class RowBasedGrouperHelper

java.lang.Object

io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper

public class RowBasedGrouperHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
RowBasedGrouperHelper()

Method Summary

Modifier and Type	Method and Description
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>>	createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories) If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not been applied to the input rows yet, for example, in a nested query, if an extraction function is being applied in the outer query to a field of the inner query.
static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row>	makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowBasedGrouperHelper

public RowBasedGrouperHelper()

Method Detail

createGrouperAccumulatorPair

public static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>> createGrouperAccumulatorPair(GroupByQuery query,
                                                                                                                                                                                                                                  boolean isInputRaw,
                                                                                                                                                                                                                                  Map<String,ValueType> rawInputRowSignature,
                                                                                                                                                                                                                                  GroupByQueryConfig config,
                                                                                                                                                                                                                                  com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
                                                                                                                                                                                                                                  int concurrencyHint,
                                                                                                                                                                                                                                  LimitedTemporaryStorage temporaryStorage,
                                                                                                                                                                                                                                  com.fasterxml.jackson.databind.ObjectMapper spillMapper,
                                                                                                                                                                                                                                  AggregatorFactory[] aggregatorFactories)

If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not been applied to the input rows yet, for example, in a nested query, if an extraction function is being applied in the outer query to a field of the inner query. This method must apply those transformations.

makeGrouperIterator

public static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row> makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper,
                                                                                                                                       GroupByQuery query,
                                                                                                                                       Closeable closeable)