public static final class OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V>
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
OptimizableRepartitionNode<K,V> |
build() |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde) |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withNodeName(java.lang.String nodeName) |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withProcessorParameters(ProcessorParameters processorParameters) |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withRepartitionTopic(java.lang.String repartitionTopic) |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withSinkName(java.lang.String sinkName) |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withSourceName(java.lang.String sourceName) |
OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> |
withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde) |
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withProcessorParameters(ProcessorParameters processorParameters)
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withSinkName(java.lang.String sinkName)
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withSourceName(java.lang.String sourceName)
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withRepartitionTopic(java.lang.String repartitionTopic)
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withNodeName(java.lang.String nodeName)
public OptimizableRepartitionNode<K,V> build()