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
-
-
Constructor Summary
Constructors Constructor Description Processor(java.lang.String name, java.util.Set<java.lang.String> stores)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object o)
int
hashCode()
java.util.Set<java.lang.String>
stores()
The names of all connected stores.java.lang.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 java.util.Set<java.lang.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
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-