Package org.apache.kafka.streams
Interface TopologyDescription.Node
-
- All Known Subinterfaces:
TopologyDescription.Processor
,TopologyDescription.Sink
,TopologyDescription.Source
- All Known Implementing Classes:
InternalTopologyBuilder.AbstractNode
,InternalTopologyBuilder.Processor
,InternalTopologyBuilder.Sink
,InternalTopologyBuilder.Source
- Enclosing interface:
- TopologyDescription
public static interface TopologyDescription.Node
A node of a topology. Can be a source, sink, or processor node.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.String
name()
The name of the node.java.util.Set<TopologyDescription.Node>
predecessors()
The predecessors of this node within a sub-topology.java.util.Set<TopologyDescription.Node>
successors()
The successor of this node within a sub-topology.
-
-
-
Method Detail
-
name
java.lang.String name()
The name of the node. Will never benull
.- Returns:
- the name of the node
-
predecessors
java.util.Set<TopologyDescription.Node> predecessors()
The predecessors of this node within a sub-topology. Note, sources do not have any predecessors. Will never benull
.- Returns:
- set of all predecessors
-
successors
java.util.Set<TopologyDescription.Node> successors()
The successor of this node within a sub-topology. Note, sinks do not have any successors. Will never benull
.- Returns:
- set of all successor
-
-