Class InternalTopologyBuilder.Processor
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode
-
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.Processor
-
- All Implemented Interfaces:
TopologyDescription.Node
,TopologyDescription.Processor
- Enclosing class:
- InternalTopologyBuilder
public static final class InternalTopologyBuilder.Processor extends InternalTopologyBuilder.AbstractNode implements TopologyDescription.Processor
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
Set<String>
stores()
The names of all connected stores.String
toString()
-
Methods inherited from class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode
addPredecessor, addSuccessor, name, predecessors, successors
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.streams.TopologyDescription.Node
name, predecessors, successors
-
-
-
-
Method Detail
-
stores
public Set<String> stores()
Description copied from interface:TopologyDescription.Processor
The names of all connected stores.- Specified by:
stores
in interfaceTopologyDescription.Processor
- Returns:
- set of store names
-
-