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.