ProcessorParameters

ProcessorParameters represents a ProcessorSupplier and a processor name to use to add a new processor (to InternalTopologyBuilder).

ProcessorParameters abstracts away different number of processors of StreamsGraphNodes (i.e. KTableKTableJoinNode, OptimizableRepartitionNode, ProcessorGraphNode, StatefulProcessorNode, StreamStreamJoinNode, StreamTableJoinNode, TableProcessorNode, and TableSourceNode) when requested to write to a topology (when InternalStreamsBuilder is requested to build a topology when StreamsBuilder is requested to build a topology).

results matching ""

    No results matching ""