Package | Description |
---|---|
io.druid.query.groupby.epinephelinae | |
io.druid.query.groupby.strategy |
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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) |
Copyright © 2011–2017. All rights reserved.