AbstractProcessor — Base for Stream Processors
AbstractProcessor is the base implementation of the Processor contract for stream processors that manages a ProcessorContext and provides a no-op implementation of close.
AbstractProcessor manages a ProcessorContext that is assigned when an AbstractProcessor is requested to initialize.
| AbstractProcessor | Description |
|---|---|
KStreamAggregateProcessor |
|
KStreamFlatMapProcessor |
|
KStreamFlatMapValuesProcessor |
|
KStreamKStreamJoinProcessor |
|
KStreamKTableJoinProcessor |
|
KStreamMapProcessor |
|
KStreamMapProcessor |
|
KStreamPassThroughProcessor |
|
KStreamPrintProcessor |
|
KStreamReduceProcessor |
|
KTableAggregateProcessor |
|
KTableFilterProcessor |
|
KTableKTableJoinMergeProcessor |
|
KTableKTableJoinProcessor |
|
KTableKTableLeftJoinProcessor |
|
KTableKTableOuterJoinProcessor |
|
KTableKTableRightJoinProcessor |
|
KTableMapProcessor |
|
KTableMapValuesProcessor |
|
KTableReduceProcessor |
|
KTableTransformValuesProcessor |