Class GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V>
-
- Enclosing class:
- GroupedTableOperationRepartitionNode<K,V>
public static final class GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> extends java.lang.Object
-
-
Method Summary
-
-
-
Method Detail
-
withKeySerde
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
-
withValueSerde
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
-
withSinkName
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withSinkName(java.lang.String sinkName)
-
withNodeName
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withNodeName(java.lang.String nodeName)
-
withSourceName
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withSourceName(java.lang.String sourceName)
-
withRepartitionTopic
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withRepartitionTopic(java.lang.String repartitionTopic)
-
withProcessorParameters
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withProcessorParameters(ProcessorParameters processorParameters)
-
build
public GroupedTableOperationRepartitionNode<K,V> build()
-
-