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

Class BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T extends BaseRepartitionNode<K,V>>

java.lang.Object

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

Direct Known Subclasses:

GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder, OptimizableRepartitionNode.OptimizableRepartitionNodeBuilder, UnoptimizableRepartitionNode.UnoptimizableRepartitionNodeBuilder

Enclosing class:

BaseRepartitionNode<K,V>

public abstract static class BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T extends BaseRepartitionNode<K,V>>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected InternalTopicProperties	internalTopicProperties
protected Serde<K>	keySerde
protected String	nodeName
protected StreamPartitioner<K,V>	partitioner
protected ProcessorParameters<K,V>	processorParameters
protected String	repartitionTopic
protected String	sinkName
protected String	sourceName
protected Serde<V>	valueSerde

Constructor Summary

Constructors

Constructor	Description
BaseRepartitionNodeBuilder()

Method Summary

Modifier and Type	Method	Description
abstract T	build()
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withInternalTopicProperties(InternalTopicProperties internalTopicProperties)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withKeySerde(Serde<K> keySerde)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withNodeName(String nodeName)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withProcessorParameters(ProcessorParameters<K,V> processorParameters)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withRepartitionTopic(String repartitionTopic)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withSinkName(String sinkName)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withSourceName(String sourceName)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withStreamPartitioner(StreamPartitioner<K,V> partitioner)
BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T>	withValueSerde(Serde<V> valueSerde)

Methods inherited from class java.lang.Object

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

Field Detail

nodeName

protected String nodeName

processorParameters

protected ProcessorParameters<K,V> processorParameters

keySerde

protected Serde<K> keySerde

valueSerde

protected Serde<V> valueSerde

sinkName

protected String sinkName

sourceName

protected String sourceName

repartitionTopic

protected String repartitionTopic

partitioner

protected StreamPartitioner<K,V> partitioner

internalTopicProperties

protected InternalTopicProperties internalTopicProperties

Constructor Detail

BaseRepartitionNodeBuilder

public BaseRepartitionNodeBuilder()

Method Detail

withProcessorParameters

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withProcessorParameters(ProcessorParameters<K,V> processorParameters)

withKeySerde

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withKeySerde(Serde<K> keySerde)

withValueSerde

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withValueSerde(Serde<V> valueSerde)

withSinkName

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withSinkName(String sinkName)

withSourceName

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withSourceName(String sourceName)

withRepartitionTopic

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withRepartitionTopic(String repartitionTopic)

withStreamPartitioner

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withStreamPartitioner(StreamPartitioner<K,V> partitioner)

withNodeName

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withNodeName(String nodeName)

withInternalTopicProperties

public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withInternalTopicProperties(InternalTopicProperties internalTopicProperties)

build

public abstract T build()