| Class | Description |
|---|---|
| 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 |
An
Assembly implementation. |
| 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 |
Copyright © 2021 The Apache Software Foundation. All rights reserved.