Class ProcessorTopology
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.ProcessorTopology
-
public class ProcessorTopology extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description 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 Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<StateStore>
globalStateStores()
boolean
hasPersistentGlobalStore()
boolean
hasPersistentLocalStore()
boolean
hasStore(java.lang.String storeName)
java.util.Set<java.lang.String>
processorConnectedStateStores(java.lang.String processorName)
java.util.List<ProcessorNode<?,?>>
processors()
SinkNode<?,?>
sink(java.lang.String topic)
java.util.Set<java.lang.String>
sinkTopics()
SourceNode<?,?>
source(java.lang.String topic)
java.util.Set<SourceNode<?,?>>
sources()
java.util.Set<java.lang.String>
sourceTopics()
java.util.List<StateStore>
stateStores()
java.util.Map<java.lang.String,java.lang.String>
storeToChangelogTopic()
java.util.Set<java.lang.String>
terminalNodes()
java.lang.String
toString()
Produces a string representation containing useful information this topology starting with the given indent.java.lang.String
toString(java.lang.String indent)
Produces a string representation containing useful information this topology.void
updateSourceTopics(java.util.Map<java.lang.String,java.util.List<java.lang.String>> allSourceTopicsByNodeName)
-
-
-
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 classjava.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)
-
-