Class BaseRepartitionNode<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode
-
- org.apache.kafka.streams.kstream.internals.graph.BaseRepartitionNode<K,V>
-
- Direct Known Subclasses:
GroupedTableOperationRepartitionNode
,OptimizableRepartitionNode
public abstract class BaseRepartitionNode<K,V> extends StreamsGraphNode
-
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.kafka.common.serialization.Serde<K>
keySerde
protected ProcessorParameters
processorParameters
protected java.lang.String
repartitionTopic
protected java.lang.String
sinkName
protected java.lang.String
sourceName
protected org.apache.kafka.common.serialization.Serde<V>
valueSerde
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
toString()
-
Methods inherited from class org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation, writeToTopology
-
-
-
-
Field Detail
-
keySerde
protected final org.apache.kafka.common.serialization.Serde<K> keySerde
-
valueSerde
protected final org.apache.kafka.common.serialization.Serde<V> valueSerde
-
sinkName
protected final java.lang.String sinkName
-
sourceName
protected final java.lang.String sourceName
-
repartitionTopic
protected final java.lang.String repartitionTopic
-
processorParameters
protected final ProcessorParameters processorParameters
-
-
Method Detail
-
toString
public java.lang.String toString()
- Overrides:
toString
in classStreamsGraphNode
-
-