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.

Table 1. AbstractProcessors
AbstractProcessor Description

KStreamAggregateProcessor

KStreamBranchProcessor

Forwards a record to exactly one of the child processors

KStreamFilterProcessor

KStreamFlatMapProcessor

KStreamFlatMapValuesProcessor

KStreamJoinWindowProcessor

KStreamKStreamJoinProcessor

KStreamKTableJoinProcessor

KStreamMapProcessor

KStreamMapProcessor

KStreamPassThroughProcessor

KStreamPeekProcessor

Executes an action with records (peeks at them)

KStreamPrintProcessor

KStreamReduceProcessor

KStreamSessionWindowAggregateProcessor

KStreamTransformProcessor

KStreamWindowAggregateProcessor

KTableAggregateProcessor

KTableFilterProcessor

KTableKTableJoinMergeProcessor

KTableKTableJoinProcessor

KTableKTableLeftJoinProcessor

KTableKTableOuterJoinProcessor

KTableKTableRightJoinProcessor

KTableMapProcessor

KTableMapValuesProcessor

KTableReduceProcessor

KTableSourceProcessor

KTableTransformValuesProcessor

results matching ""

    No results matching ""