public class ProcessorNode<K,V>
extends Object

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addChild(ProcessorNode<?,?> child)`
`List<ProcessorNode<?,?>>`	`children()`
`void`	`close()`
`void`	`init(InternalProcessorContext context)`
`boolean`	`isTerminalNode()`
`String`	`name()`
`void`	`process(K key, V value)`
`Processor<K,V>`	`processor()`
`void`	`punctuate(long timestamp, Punctuator punctuator)`
`String`	`toString()`
`String`	`toString(String indent)`

public ProcessorNode(String name,
                     Processor<K,V> processor,
                     Set<String> stateStores)

public final Processor<K,V> processor()

public List<ProcessorNode<?,?>> children()

public void addChild(ProcessorNode<?,?> child)

public void init(InternalProcessorContext context)

public void process(K key,
                    V value)

public void punctuate(long timestamp,
                      Punctuator punctuator)

Constructor	Description
`ProcessorNode(String name)`
`ProcessorNode(String name, Processor<K,V> processor, Set<String> stateStores)`

Class ProcessorNode<K,​V>

Class ProcessorNode<K,V>