Interface StreamsGroupTopologyDescription.Node

All Known Implementing Classes:
StreamsGroupTopologyDescription.Processor, StreamsGroupTopologyDescription.Sink, StreamsGroupTopologyDescription.Source
Enclosing class:
StreamsGroupTopologyDescription
public static interface StreamsGroupTopologyDescription.Node
A node of a topology. Can be a StreamsGroupTopologyDescription.Source, StreamsGroupTopologyDescription.Sink, or StreamsGroupTopologyDescription.Processor node.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    name()
    The name of this node.
    Set<String>
    predecessors()
    The names of the predecessor nodes within the subtopology, reconstructed from the successor relation.
    Set<String>
    successors()
    The names of the successor nodes within the subtopology.

  • Method Details

    • name

      String name()
      The name of this node.

    • successors

      Set<String> successors()
      The names of the successor nodes within the subtopology.

    • predecessors

      Set<String> predecessors()
      The names of the predecessor nodes within the subtopology, reconstructed from the successor relation.