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