| Interface | Description |
|---|---|
| BatchIterator | |
| HashAggregator | |
| StreamingAggregator |
| Class | Description |
|---|---|
| HashAggBatch | |
| HashAggBatchCreator | |
| HashAggSpilledPartition | |
| HashAggTemplate | |
| HashAggUpdater | |
| InternalBatch | |
| SpilledRecordBatch |
Replaces "incoming" - instead scanning a spilled partition file
|
| StreamingAggBatch | |
| StreamingAggBatchCreator | |
| StreamingAggTemplate |
| Enum | Description |
|---|---|
| HashAggregator.AggIterOutcome | |
| HashAggregator.AggOutcome | |
| HashAggTemplate.Metric | |
| StreamingAggregator.AggOutcome |
The Aggregator can return one of the following outcomes:
|
Copyright © 1970 The Apache Software Foundation. All rights reserved.