public class OptimizableRepartitionNode<K,V> extends BaseRepartitionNode
Modifier and Type | Class and Description |
---|---|
static class |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
keySerde, processorParameters, repartitionTopic, sinkName, sourceName, valueSerde
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<K> |
keySerde() |
static <K,V> OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
optimizableRepartitionNodeBuilder() |
java.lang.String |
repartitionTopic() |
java.lang.String |
toString() |
org.apache.kafka.common.serialization.Serde<V> |
valueSerde() |
void |
writeToTopology(InternalTopologyBuilder topologyBuilder) |
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
public java.lang.String repartitionTopic()
public java.lang.String toString()
toString
in class BaseRepartitionNode
public void writeToTopology(InternalTopologyBuilder topologyBuilder)
writeToTopology
in class StreamsGraphNode
public static <K,V> OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> optimizableRepartitionNodeBuilder()