Class ProcessorTopology


  • public class ProcessorTopology
    extends java.lang.Object
    • Constructor Detail

      • ProcessorTopology

        public ProcessorTopology​(java.util.List<ProcessorNode> processorNodes,
                                 java.util.Map<java.lang.String,​SourceNode> sourcesByTopic,
                                 java.util.Map<java.lang.String,​SinkNode> sinksByTopic,
                                 java.util.List<StateStore> stateStores,
                                 java.util.List<StateStore> globalStateStores,
                                 java.util.Map<java.lang.String,​java.lang.String> stateStoreToChangelogTopic,
                                 java.util.Set<java.lang.String> repartitionTopics)
    • Method Detail

      • with

        public static ProcessorTopology with​(java.util.List<ProcessorNode> processorNodes,
                                             java.util.Map<java.lang.String,​SourceNode> sourcesByTopic,
                                             java.util.List<StateStore> stateStoresByName,
                                             java.util.Map<java.lang.String,​java.lang.String> storeToChangelogTopic)
      • sourceTopics

        public java.util.Set<java.lang.String> sourceTopics()
      • source

        public SourceNode source​(java.lang.String topic)
      • sources

        public java.util.Set<SourceNode> sources()
      • sinkTopics

        public java.util.Set<java.lang.String> sinkTopics()
      • sink

        public SinkNode sink​(java.lang.String topic)
      • sinks

        public java.util.Set<SinkNode> sinks()
      • stateStores

        public java.util.List<StateStore> stateStores()
      • globalStateStores

        public java.util.List<StateStore> globalStateStores()
      • storeToChangelogTopic

        public java.util.Map<java.lang.String,​java.lang.String> storeToChangelogTopic()
      • toString

        public java.lang.String toString()
        Produces a string representation containing useful information this topology starting with the given indent. This is useful in debugging scenarios.
        Overrides:
        toString in class java.lang.Object
        Returns:
        A string representation of this instance.
      • toString

        public java.lang.String toString​(java.lang.String indent)
        Produces a string representation containing useful information this topology. This is useful in debugging scenarios.
        Returns:
        A string representation of this instance.
      • processorConnectedStateStores

        public java.util.Set<java.lang.String> processorConnectedStateStores​(java.lang.String processorName)