Package org.apache.kafka.streams
Interface TopologyDescription.Node
-
- All Known Subinterfaces:
TopologyDescription.Processor
,TopologyDescription.Sink
,TopologyDescription.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 String
name()
The name of the node.Set<TopologyDescription.Node>
predecessors()
The predecessors of this node within a sub-topology.Set<TopologyDescription.Node>
successors()
The successor of this node within a sub-topology.
-
-
-
Method Detail
-
name
String name()
The name of the node. Will never benull
.- Returns:
- the name of the node
-
predecessors
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
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
-
-