Class InternalTopologyBuilder.Subtopology
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.Subtopology
-
- All Implemented Interfaces:
TopologyDescription.Subtopology
- Enclosing class:
- InternalTopologyBuilder
public static final class InternalTopologyBuilder.Subtopology extends Object implements TopologyDescription.Subtopology
-
-
Constructor Summary
Constructors Constructor Description Subtopology(int id, Set<TopologyDescription.Node> nodes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
int
id()
Internally assigned unique ID.Set<TopologyDescription.Node>
nodes()
All nodes of this sub-topology.String
toString()
-
-
-
Constructor Detail
-
Subtopology
public Subtopology(int id, Set<TopologyDescription.Node> nodes)
-
-
Method Detail
-
id
public int id()
Description copied from interface:TopologyDescription.Subtopology
Internally assigned unique ID.- Specified by:
id
in interfaceTopologyDescription.Subtopology
- Returns:
- the ID of the sub-topology
-
nodes
public Set<TopologyDescription.Node> nodes()
Description copied from interface:TopologyDescription.Subtopology
All nodes of this sub-topology.- Specified by:
nodes
in interfaceTopologyDescription.Subtopology
- Returns:
- set of all nodes within the sub-topology
-
-