| ComparisonAggregator<T> |
Abstract Aggregator for comparing two values in a stream.
|
| ComparisonAggregator.State |
|
| Count |
|
| Debug |
Filter for debugging purposes.
|
| Equals |
|
| FilterNull |
Simple `Filter` implementation that filters out any tuples that have fields with a value of `null`.
|
| FirstN |
|
| FirstN.FirstNAgg |
|
| FirstN.FirstNSortedAgg |
|
| MapGet |
|
| Max |
This aggregator computes the maximum of aggregated tuples in a stream.
|
| MaxWithComparator<T> |
This aggregator computes the maximum of aggregated tuples in a stream.
|
| Min |
This aggregator computes the minimum of aggregated tuples in a stream.
|
| MinWithComparator<T> |
This aggregator computes the minimum of aggregated tuples in a stream.
|
| Negate |
A `Filter` implementation that inverts another delegate `Filter`.
|
| SnapshotGet |
|
| Sum |
|
| TupleCollectionGet |
|