| Class | Description |
|---|---|
| AggregateProcessor | |
| AppendCollector | |
| EachProcessor | |
| FreshCollector | |
| MapProcessor |
Processor for executing
Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions. |
| MultiReducerProcessor | |
| PartitionPersistProcessor | |
| ProjectedProcessor | |
| StateQueryProcessor | |
| TridentContext |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.