Package org.apache.kafka.streams.processor.internals

Class InternalTopologyBuilder.AbstractNode

java.lang.Object

org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode

All Implemented Interfaces:

TopologyDescription.Node

Direct Known Subclasses:

InternalTopologyBuilder.Processor, InternalTopologyBuilder.Sink, InternalTopologyBuilder.Source

Enclosing class:

InternalTopologyBuilder

public abstract static class InternalTopologyBuilder.AbstractNode
extends Object
implements TopologyDescription.Node

Method Summary

Modifier and Type	Method	Description
void	addPredecessor(TopologyDescription.Node predecessor)
void	addSuccessor(TopologyDescription.Node successor)
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

name

public String name()

Description copied from interface: TopologyDescription.Node

The name of the node. Will never be null.

Specified by:

name in interface TopologyDescription.Node

Returns:

the name of the node

predecessors

public Set<TopologyDescription.Node> predecessors()

Description copied from interface: TopologyDescription.Node

The predecessors of this node within a sub-topology. Note, sources do not have any predecessors. Will never be null.

Specified by:

predecessors in interface TopologyDescription.Node

Returns:

set of all predecessors

successors

public Set<TopologyDescription.Node> successors()

Description copied from interface: TopologyDescription.Node

The successor of this node within a sub-topology. Note, sinks do not have any successors. Will never be null.

Specified by:

successors in interface TopologyDescription.Node

Returns:

set of all successor

addPredecessor

public void addPredecessor(TopologyDescription.Node predecessor)

addSuccessor

public void addSuccessor(TopologyDescription.Node successor)