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

Class SourceNode<K,V>

java.lang.Object

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

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

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

Field Summary

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

stateStores

Constructor Summary

Constructors

Constructor	Description
SourceNode(String name, Deserializer<K> keyDeserializer, Deserializer<V> valDeserializer)
SourceNode(String name, TimestampExtractor timestampExtractor, Deserializer<K> keyDeserializer, Deserializer<V> valDeserializer)

Method Summary

Modifier and Type	Method	Description
TimestampExtractor	getTimestampExtractor()
void	init(InternalProcessorContext context)
void	process(K key, V value)
String	toString()

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

addChild, children, close, isTerminalNode, name, processor, punctuate, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceNode

public SourceNode(String name,
                  TimestampExtractor timestampExtractor,
                  Deserializer<K> keyDeserializer,
                  Deserializer<V> valDeserializer)

SourceNode

public SourceNode(String name,
                  Deserializer<K> keyDeserializer,
                  Deserializer<V> valDeserializer)

Method Detail

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.

getTimestampExtractor

public TimestampExtractor getTimestampExtractor()