public class ProcessorTopology
extends java.lang.Object
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
java.util.List<StateStore> |
globalStateStores() |
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<SinkNode> |
sinks() |
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.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.
|
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) |
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)
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)
public java.util.Set<java.lang.String> sourceTopics()
public SourceNode source(java.lang.String topic)
public java.util.Set<SourceNode> sources()
public java.util.Set<java.lang.String> sinkTopics()
public SinkNode sink(java.lang.String topic)
public java.util.Set<SinkNode> sinks()
public java.util.List<ProcessorNode> processors()
public java.util.List<StateStore> stateStores()
public java.util.List<StateStore> globalStateStores()
public java.util.Map<java.lang.String,java.lang.String> storeToChangelogTopic()
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String toString(java.lang.String indent)
public java.util.Set<java.lang.String> processorConnectedStateStores(java.lang.String processorName)