void writeToTopology(final InternalTopologyBuilder topologyBuilder)ProcessorGraphNode
ProcessorGraphNode is a graph node for stateless operators in KStreamImpl and KTableImpl.
When requested to writeToTopology, ProcessorGraphNode simply requests the given InternalTopologyBuilder to add a processor (with the name and the ProcessorSupplier as defined by the given ProcessorParameters).
ProcessorGraphNode is created when:
-
KStreamImplis requested to filter, filterNot, internalSelectKey (for selectKey and groupBy operators), map, mapValues, print, flatMap, flatMapValues, branch, merge, foreach, peek -
KStreamImplJoinis requested to join (whenKStreamImplis requested to doJoin for join, outerJoin and leftJoin join operators)
ProcessorGraphNode takes the following to be created:
writeToTopology Method
|
Note
|
writeToTopology is part of the StreamsGraphNode Contract to…FIXME.
|
writeToTopology requests the given InternalTopologyBuilder to add a processor with the name and the ProcessorSupplier as defined by the given ProcessorParameters.