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 java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected InternalTopicProperties
internalTopicProperties
protected org.apache.kafka.common.serialization.Serde<K>
keySerde
protected java.lang.String
nodeName
protected StreamPartitioner<K,V>
partitioner
protected ProcessorParameters<K,V>
processorParameters
protected java.lang.String
repartitionTopic
protected java.lang.String
sinkName
protected java.lang.String
sourceName
protected org.apache.kafka.common.serialization.Serde<V>
valueSerde
-
Constructor Summary
Constructors Constructor Description BaseRepartitionNodeBuilder()
-
Method Summary
-
-
-
Field Detail
-
nodeName
protected java.lang.String nodeName
-
processorParameters
protected ProcessorParameters<K,V> processorParameters
-
keySerde
protected org.apache.kafka.common.serialization.Serde<K> keySerde
-
valueSerde
protected org.apache.kafka.common.serialization.Serde<V> valueSerde
-
sinkName
protected java.lang.String sinkName
-
sourceName
protected java.lang.String sourceName
-
repartitionTopic
protected java.lang.String repartitionTopic
-
partitioner
protected StreamPartitioner<K,V> partitioner
-
internalTopicProperties
protected InternalTopicProperties internalTopicProperties
-
-
Method Detail
-
withProcessorParameters
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withProcessorParameters(ProcessorParameters<K,V> processorParameters)
-
withKeySerde
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
-
withValueSerde
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
-
withSinkName
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withSinkName(java.lang.String sinkName)
-
withSourceName
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withSourceName(java.lang.String sourceName)
-
withRepartitionTopic
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withRepartitionTopic(java.lang.String repartitionTopic)
-
withStreamPartitioner
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withStreamPartitioner(StreamPartitioner<K,V> partitioner)
-
withNodeName
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withNodeName(java.lang.String nodeName)
-
withInternalTopicProperties
public BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,T> withInternalTopicProperties(InternalTopicProperties internalTopicProperties)
-
build
public abstract T build()
-
-