public class SourceNode<K,V> extends ProcessorNode<K,V>
stateStores
Constructor and 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) |
Modifier and Type | Method and 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) |
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)
public 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>
public TimestampExtractor getTimestampExtractor()