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<?,​?>> sourceNodesByTopic,
                                 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> storeToChangelogTopic,
                                 java.util.Set<java.lang.String> repartitionTopics)
    • Method Detail

      • 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)
      • terminalNodes

        public java.util.Set<java.lang.String> terminalNodes()
      • processors

        public java.util.List<ProcessorNode<?,​?>> processors()
      • stateStores

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

        public boolean hasStore​(java.lang.String storeName)
      • globalStateStores

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

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

        public boolean hasPersistentLocalStore()
      • hasPersistentGlobalStore

        public boolean hasPersistentGlobalStore()
      • updateSourceTopics

        public void updateSourceTopics​(java.util.Map<java.lang.String,​java.util.List<java.lang.String>> allSourceTopicsByNodeName)
      • 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)