Package org.apache.kafka.streams.processor.internals

Class SinkNode<K,V>

java.lang.Object

org.apache.kafka.streams.processor.internals.ProcessorNode<K,V>

org.apache.kafka.streams.processor.internals.SinkNode<K,V>

public class SinkNode<K,V>
extends ProcessorNode<K,V>

Field Summary

Fields inherited from class org.apache.kafka.streams.processor.internals.ProcessorNode

stateStores

Method Summary

Modifier and Type	Method	Description
void	addChild(ProcessorNode<?,?> child)
void	init(InternalProcessorContext context)
void	process(K key, V value)
String	toString()
String	toString(String indent)

Methods inherited from class org.apache.kafka.streams.processor.internals.ProcessorNode

children, close, isTerminalNode, name, processor, punctuate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

addChild

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

Overrides:

addChild in class ProcessorNode<K,V>

Throws:

UnsupportedOperationException - if this method adds a child to a sink node

init

public void init(InternalProcessorContext context)

Overrides:

init in class ProcessorNode<K,V>

process

public void process(K key,
                    V value)

Overrides:

process in class ProcessorNode<K,V>

toString

public String toString()

Overrides:

toString in class ProcessorNode<K,V>

Returns:

a string representation of this node, useful for debugging.

toString

public String toString(String indent)

Overrides:

toString in class ProcessorNode<K,V>

Returns:

a string representation of this node starting with the given indent, useful for debugging.