| Class | Description |
|---|---|
| BatchMap<T> | |
| BatchMapKey |
Unique ids for a batch are simply built by concatenating the batch number
(monotonically increasing counter set up by the Kafka Spout) with the source partition number.
|
| CountFieldOperation | |
| CountFieldValueOperation | |
| CountOperation | |
| Key | |
| Operation | |
| Record |
A Record keeps track of the various counter associated to the keys identifying one aggregation.
|
| RecordKey | |
| SumOperation | |
| Timestamp |
Copyright © 2022. All rights reserved.