ProcessorGraphNode is a GraphNode.
ProcessorGraphNode takes the following to be created:
- Node Name
ProcessorGraphNode is created when:
BranchedKStreamImplis created and requested to
CogroupedStreamAggregateBuilderis requested to
KStreamImplis requested to filter, filterNot, internalSelectKey, map, mapValues, flatMap, flatMapValues, print, foreach, peek, doBranch, merge
KStreamImplJoinis requested to join
KTableImplis requested to doJoinOnForeignKey, toStream, groupBy
void writeToTopology( InternalTopologyBuilder topologyBuilder, Properties props)
writeToTopology is part of the GraphNode abstraction.