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

Class UnoptimizableRepartitionNode.UnoptimizableRepartitionNodeBuilder<K,V>

java.lang.Object

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

org.apache.kafka.streams.kstream.internals.graph.UnoptimizableRepartitionNode.UnoptimizableRepartitionNodeBuilder<K,V>

Enclosing class:

UnoptimizableRepartitionNode<K,V>

public static final class UnoptimizableRepartitionNode.UnoptimizableRepartitionNodeBuilder<K,V>
extends BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,UnoptimizableRepartitionNode<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
UnoptimizableRepartitionNodeBuilder()

Method Summary

Modifier and Type	Method	Description
UnoptimizableRepartitionNode<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

UnoptimizableRepartitionNodeBuilder

public UnoptimizableRepartitionNodeBuilder()

Method Detail

build

public UnoptimizableRepartitionNode<K,V> build()

Specified by:

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