Package org.apache.kafka.streams.processor.internals

Class ProcessorTopology

java.lang.Object

org.apache.kafka.streams.processor.internals.ProcessorTopology

public class ProcessorTopology
extends Object

Constructor Summary

Constructors

Constructor	Description
ProcessorTopology(List<ProcessorNode<?,?>> processorNodes, Map<String,SourceNode<?,?>> sourceNodesByTopic, Map<String,SinkNode<?,?>> sinksByTopic, List<StateStore> stateStores, List<StateStore> globalStateStores, Map<String,String> storeToChangelogTopic, Set<String> repartitionTopics)

Method Summary

Modifier and Type	Method	Description
List<StateStore>	globalStateStores()
boolean	hasPersistentGlobalStore()
boolean	hasPersistentLocalStore()
boolean	hasStore(String storeName)
Set<String>	processorConnectedStateStores(String processorName)
List<ProcessorNode<?,?>>	processors()
SinkNode<?,?>	sink(String topic)
Set<String>	sinkTopics()
SourceNode<?,?>	source(String topic)
Set<SourceNode<?,?>>	sources()
Set<String>	sourceTopics()
List<StateStore>	stateStores()
Map<String,String>	storeToChangelogTopic()
Set<String>	terminalNodes()
String	toString()	Produces a string representation containing useful information this topology starting with the given indent.
String	toString(String indent)	Produces a string representation containing useful information this topology.
void	updateSourceTopics(Map<String,List<String>> allSourceTopicsByNodeName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ProcessorTopology

public ProcessorTopology(List<ProcessorNode<?,?>> processorNodes,
                         Map<String,SourceNode<?,?>> sourceNodesByTopic,
                         Map<String,SinkNode<?,?>> sinksByTopic,
                         List<StateStore> stateStores,
                         List<StateStore> globalStateStores,
                         Map<String,String> storeToChangelogTopic,
                         Set<String> repartitionTopics)

Method Detail

sourceTopics

public Set<String> sourceTopics()

source

public SourceNode<?,?> source(String topic)

sources

public Set<SourceNode<?,?>> sources()

sinkTopics

public Set<String> sinkTopics()

sink

public SinkNode<?,?> sink(String topic)

terminalNodes

public Set<String> terminalNodes()

processors

public List<ProcessorNode<?,?>> processors()

stateStores

public List<StateStore> stateStores()

hasStore

public boolean hasStore(String storeName)

globalStateStores

public List<StateStore> globalStateStores()

storeToChangelogTopic

public Map<String,String> storeToChangelogTopic()

hasPersistentLocalStore

public boolean hasPersistentLocalStore()

hasPersistentGlobalStore

public boolean hasPersistentGlobalStore()

updateSourceTopics

public void updateSourceTopics(Map<String,List<String>> allSourceTopicsByNodeName)

toString

public 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 Object

Returns:

A string representation of this instance.

toString

public String toString(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 Set<String> processorConnectedStateStores(String processorName)