| 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,
       int mergeBufferSize)  | 
| 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–2018. All rights reserved.