public class SinkNode<K,V> extends ProcessorNode<K,V>
stateStores
Modifier and Type | Method and Description |
---|---|
void |
addChild(ProcessorNode<?,?> child) |
void |
init(InternalProcessorContext context) |
void |
process(K key,
V value) |
java.lang.String |
toString() |
java.lang.String |
toString(java.lang.String indent) |
public void addChild(ProcessorNode<?,?> child)
addChild
in class ProcessorNode<K,V>
java.lang.UnsupportedOperationException
- if this method adds a child to a sink nodepublic void init(InternalProcessorContext context)
init
in class ProcessorNode<K,V>
public java.lang.String toString()
toString
in class ProcessorNode<K,V>
public java.lang.String toString(java.lang.String indent)
toString
in class ProcessorNode<K,V>