| 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 | Class and Description |
|---|---|
class |
StreamingAggTemplate |
| Modifier and Type | Field and Description |
|---|---|
protected StreamingAggregator |
StreamingAggBatch.aggregator |
| Modifier and Type | Field and Description |
|---|---|
static TemplateClassDefinition<StreamingAggregator> |
StreamingAggregator.TEMPLATE_DEFINITION |
| Modifier and Type | Method and Description |
|---|---|
protected StreamingAggregator |
StreamingAggBatch.createAggregatorInternal() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
StreamingAggBatch.addRecordValues(ClassGenerator<StreamingAggregator> cg,
LogicalExpression[] valueExprs) |
protected void |
StreamingAggBatch.getIndex(ClassGenerator<StreamingAggregator> g) |
protected void |
StreamingAggBatch.outputRecordKeys(ClassGenerator<StreamingAggregator> cg,
TypedFieldId[] keyOutputIds,
LogicalExpression[] keyExprs) |
protected void |
StreamingAggBatch.outputRecordKeysPrev(ClassGenerator<StreamingAggregator> cg,
TypedFieldId[] keyOutputIds,
LogicalExpression[] keyExprs) |
protected void |
StreamingAggBatch.setupIsSame(ClassGenerator<StreamingAggregator> cg,
LogicalExpression[] keyExprs) |
protected void |
StreamingAggBatch.setupIsSameApart(ClassGenerator<StreamingAggregator> cg,
LogicalExpression[] keyExprs) |
| Modifier and Type | Method and Description |
|---|---|
protected StreamingAggregator |
MetadataStreamAggBatch.createAggregatorInternal() |
| Modifier and Type | Method and Description |
|---|---|
protected StreamingAggregator |
StatisticsAggBatch.createAggregatorInternal() |
Copyright © 2021 The Apache Software Foundation. All rights reserved.