Class OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V>
-
- Enclosing class:
- OptimizableRepartitionNode<K,V>
public static final class OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> extends java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Method Detail
-
withProcessorParameters
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withProcessorParameters(ProcessorParameters processorParameters)
-
withKeySerde
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
-
withValueSerde
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
-
withSinkName
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withSinkName(java.lang.String sinkName)
-
withSourceName
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withSourceName(java.lang.String sourceName)
-
withRepartitionTopic
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withRepartitionTopic(java.lang.String repartitionTopic)
-
withNodeName
public OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V> withNodeName(java.lang.String nodeName)
-
build
public OptimizableRepartitionNode<K,V> build()
-
-