Package | Description |
---|---|
io.druid.query.groupby | |
io.druid.query.groupby.epinephelinae | |
io.druid.query.groupby.strategy | |
io.druid.sql.calcite.rel |
Modifier and Type | Method and Description |
---|---|
GroupByQuery |
GroupByQuery.Builder.build() |
GroupByQuery |
GroupByQuery.withDimensionSpecs(List<DimensionSpec> dimensionSpecs) |
GroupByQuery |
GroupByQuery.withDimFilter(DimFilter dimFilter) |
GroupByQuery |
GroupByQuery.withLimitSpec(LimitSpec limitSpec) |
GroupByQuery |
GroupByQuery.withOverriddenContext(Map<String,Object> contextOverride) |
GroupByQuery |
GroupByQuery.withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs) |
GroupByQuery |
GroupByQuery.withQuerySegmentSpec(QuerySegmentSpec spec) |
Modifier and Type | Method and Description |
---|---|
CacheStrategy<Row,Object,GroupByQuery> |
GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query) |
QueryToolChest<Row,GroupByQuery> |
GroupByQueryRunnerFactory.getToolchest() |
Modifier and Type | Method and Description |
---|---|
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
boolean combine) |
static Collection<DimensionSpec> |
GroupByQueryQueryToolChest.extractionsToRewrite(GroupByQuery query)
This function checks the query for dimensions which can be optimized by applying the dimension extraction
as the final step of the query instead of on every event.
|
CacheStrategy<Row,Object,GroupByQuery> |
GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query) |
void |
GroupByQueryMetrics.granularity(GroupByQuery query)
Sets the granularity of
BaseQuery.getGranularity() of the given query as dimension. |
void |
DefaultGroupByQueryMetrics.granularity(GroupByQuery query) |
static IncrementalIndex |
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
GroupByQueryMetrics |
GroupByQueryQueryToolChest.makeMetrics(GroupByQuery query) |
com.google.common.base.Function<Row,Row> |
GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<Row,Row> |
GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
void |
GroupByQueryMetrics.numComplexMetrics(GroupByQuery query)
Sets the number of "complex" metrics of the given groupBy query as dimension.
|
void |
DefaultGroupByQueryMetrics.numComplexMetrics(GroupByQuery query) |
void |
GroupByQueryMetrics.numDimensions(GroupByQuery query)
Sets the size of
getDimensions() of the given query as dimension. |
void |
DefaultGroupByQueryMetrics.numDimensions(GroupByQuery query) |
void |
GroupByQueryMetrics.numMetrics(GroupByQuery query)
Sets the number of metrics of the given groupBy query as dimension.
|
void |
DefaultGroupByQueryMetrics.numMetrics(GroupByQuery query) |
static Sequence<Row> |
GroupByQueryHelper.postAggregate(GroupByQuery query,
IncrementalIndex index) |
Sequence<Row> |
GroupByQueryEngine.process(GroupByQuery query,
StorageAdapter storageAdapter) |
void |
DefaultGroupByQueryMetrics.query(GroupByQuery query) |
static Map<String,ValueType> |
GroupByQueryHelper.rowSignatureFor(GroupByQuery query)
Returns types for fields that will appear in the Rows output from "query".
|
GroupByQueryConfig |
GroupByQueryConfig.withOverrides(GroupByQuery query) |
Constructor and Description |
---|
Builder(GroupByQuery query) |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
int mergeBufferSize)
Create a single-threaded grouper and accumulator.
|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
com.google.common.util.concurrent.ListeningExecutorService grouperSorter,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt,
int mergeBufferSize)
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> |
RowBasedGrouperHelper.makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper,
GroupByQuery query,
Closeable closeable) |
static Sequence<Row> |
GroupByQueryEngineV2.process(GroupByQuery query,
StorageAdapter storageAdapter,
NonBlockingPool<ByteBuffer> intermediateResultsBufferPool,
GroupByQueryConfig config) |
Constructor and Description |
---|
GroupByBinaryFnV2(GroupByQuery query) |
Modifier and Type | Method and Description |
---|---|
boolean |
GroupByStrategyV2.doMergeResults(GroupByQuery query) |
boolean |
GroupByStrategyV1.doMergeResults(GroupByQuery query) |
boolean |
GroupByStrategy.doMergeResults(GroupByQuery query)
Indicates if this query should undergo "mergeResults" or not.
|
static org.joda.time.DateTime |
GroupByStrategyV2.getUniversalTimestamp(GroupByQuery query)
If "query" has a single universal timestamp, return it.
|
Sequence<Row> |
GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
Sequence<Row> |
GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
Sequence<Row> |
GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner,
GroupByQuery query,
Map<String,Object> responseContext) |
GroupByQueryResource |
GroupByStrategyV2.prepareResource(GroupByQuery query,
boolean willMergeRunners) |
GroupByQueryResource |
GroupByStrategyV1.prepareResource(GroupByQuery query,
boolean willMergeRunners) |
GroupByQueryResource |
GroupByStrategy.prepareResource(GroupByQuery query,
boolean willMergeRunners)
Initializes resources required for a broker to process the given query.
|
Sequence<Row> |
GroupByStrategyV2.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Sequence<Row> |
GroupByStrategyV1.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Sequence<Row> |
GroupByStrategy.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Sequence<Row> |
GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategy.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
GroupByStrategy |
GroupByStrategySelector.strategize(GroupByQuery query) |
Modifier and Type | Method and Description |
---|---|
GroupByQuery |
DruidQuery.toGroupByQuery()
Return this query as a GroupBy query, or null if this query is not compatible with GroupBy.
|
Copyright © 2011–2018. All rights reserved.