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(java.lang.String name, java.util.List<java.lang.String> topics, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)
SourceNode(java.lang.String name, java.util.List<java.lang.String> topics, TimestampExtractor timestampExtractor, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TimestampExtractor
getTimestampExtractor()
void
init(InternalProcessorContext context)
void
process(K key, V value)
java.lang.String
toString()
java.lang.String
toString(java.lang.String indent)
-
-
-
Constructor Detail
-
SourceNode
public SourceNode(java.lang.String name, java.util.List<java.lang.String> topics, TimestampExtractor timestampExtractor, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)
-
-
Method Detail
-
init
public void init(InternalProcessorContext context)
- Overrides:
init
in classProcessorNode<K,V>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classProcessorNode<K,V>
- Returns:
- a string representation of this node, useful for debugging.
-
toString
public java.lang.String toString(java.lang.String indent)
- Overrides:
toString
in classProcessorNode<K,V>
- Returns:
- a string representation of this node starting with the given indent, useful for debugging.
-
getTimestampExtractor
public TimestampExtractor getTimestampExtractor()
-
-