Class ProcessorNode<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.ProcessorNode<K,V>
-
- Direct Known Subclasses:
SinkNode
,SourceNode
public class ProcessorNode<K,V> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description java.util.Set<java.lang.String>
stateStores
-
Constructor Summary
Constructors Constructor Description ProcessorNode(java.lang.String name)
ProcessorNode(java.lang.String name, Processor<K,V> processor, java.util.Set<java.lang.String> stateStores)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addChild(ProcessorNode<?,?> child)
java.util.List<ProcessorNode<?,?>>
children()
void
close()
void
init(InternalProcessorContext context)
java.lang.String
name()
void
process(K key, V value)
Processor<K,V>
processor()
void
punctuate(long timestamp, Punctuator punctuator)
java.lang.String
toString()
java.lang.String
toString(java.lang.String indent)
-
-
-
Method Detail
-
name
public final java.lang.String name()
-
children
public final java.util.List<ProcessorNode<?,?>> children()
-
addChild
public void addChild(ProcessorNode<?,?> child)
-
init
public void init(InternalProcessorContext context)
-
close
public void close()
-
punctuate
public void punctuate(long timestamp, Punctuator punctuator)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
- Returns:
- a string representation of this node, useful for debugging.
-
toString
public java.lang.String toString(java.lang.String indent)
- Returns:
- a string representation of this node starting with the given indent, useful for debugging.
-
-