ProcessorGraphNode¶

ProcessorGraphNode is a GraphNode.

Creating Instance¶

ProcessorGraphNode takes the following to be created:

• Node Name
• ProcessorParameters

ProcessorGraphNode is created when:

• BranchedKStreamImpl is created and requested to createBranch
• CogroupedStreamAggregateBuilder is requested to createTable
• KStreamImpl is requested to filter, filterNot, internalSelectKey, map, mapValues, flatMap, flatMapValues, print, foreach, peek, doBranch, merge
• KStreamImplJoin is requested to join
• KTableImpl is requested to doJoinOnForeignKey, toStream, groupBy

writeToTopology¶

void writeToTopology(
  InternalTopologyBuilder topologyBuilder,
  Properties props)

writeToTopology requests the given InternalTopologyBuilder to addProcessor (with the processorName and processorSupplier of the ProcessorParameters and parentNodeNames)

writeToTopology is part of the GraphNode abstraction.