public abstract class BaseRepartitionNode<K,V> extends StreamsGraphNode
Modifier and Type | Field and 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 |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
toString() |
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation, writeToTopology
protected final org.apache.kafka.common.serialization.Serde<K> keySerde
protected final org.apache.kafka.common.serialization.Serde<V> valueSerde
protected final java.lang.String sinkName
protected final java.lang.String sourceName
protected final java.lang.String repartitionTopic
protected final ProcessorParameters processorParameters
public java.lang.String toString()
toString
in class StreamsGraphNode