| Package | Description |
|---|---|
| org.apache.drill.exec.physical.impl.aggregate | |
| org.apache.drill.exec.physical.impl.metadata | |
| org.apache.drill.exec.physical.impl.statistics |
| Modifier and Type | Method and Description |
|---|---|
StreamingAggBatch |
StreamingAggBatchCreator.getBatch(ExecutorFragmentContext context,
StreamingAggregate config,
List<RecordBatch> children) |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamingAggregator.setup(OperatorContext context,
RecordBatch incoming,
StreamingAggBatch outgoing,
int outputRowCount) |
void |
StreamingAggTemplate.setup(OperatorContext context,
RecordBatch incoming,
StreamingAggBatch outgoing,
int outputRowCount) |
| Modifier and Type | Class and Description |
|---|---|
class |
MetadataStreamAggBatch
Operator which adds aggregate calls for all incoming columns to calculate
required metadata and produces aggregations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StatisticsAggBatch |
Copyright © 2021 The Apache Software Foundation. All rights reserved.