ProcessorTopology¶

Creating Instance¶

ProcessorTopology takes the following to be created:

• ProcessorNodes
• SourceNodes by topic
• SinkNodes by topic
• StateStores
• Global StateStores
• Store names by topic
• Repartition topics

ProcessorTopology is created when:

• InternalTopologyBuilder is requested to build a ProcessorTopology

Text Representation¶

String toString() // (1)
String toString(
  String indent)

1. Uses an empty indent (to start recursion)

toString...FIXME

toString is part of the Object (Java) abstraction.

childrenToString¶

String childrenToString(
  String indent, 
  List<? extends ProcessorNode<?, ?, ?, ?>> children)

childrenToString...FIXME