Package org.apache.kafka.streams.kstream.internals.graph

Class OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.internals.graph.BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,OptimizableRepartitionNode<K,V>>

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 BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,OptimizableRepartitionNode<K,V>>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.internals.graph.BaseRepartitionNode.BaseRepartitionNodeBuilder

internalTopicProperties, keySerde, nodeName, partitioner, processorParameters, repartitionTopic, sinkName, sourceName, valueSerde

Constructor Summary

Constructors

Constructor	Description
OptimizableRepartitionNodeBuilder()

Method Summary

Modifier and Type	Method	Description
OptimizableRepartitionNode<K,V>	build()

Methods inherited from class org.apache.kafka.streams.kstream.internals.graph.BaseRepartitionNode.BaseRepartitionNodeBuilder

withInternalTopicProperties, withKeySerde, withNodeName, withProcessorParameters, withRepartitionTopic, withSinkName, withSourceName, withStreamPartitioner, withValueSerde

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OptimizableRepartitionNodeBuilder

public OptimizableRepartitionNodeBuilder()

Method Detail

build

public OptimizableRepartitionNode<K,V> build()

Specified by:

build in class BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,OptimizableRepartitionNode<K,V>>