public static final class GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V>
extends java.lang.Object
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withSinkName(java.lang.String sinkName)
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withNodeName(java.lang.String nodeName)
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withSourceName(java.lang.String sourceName)
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withRepartitionTopic(java.lang.String repartitionTopic)
public GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V> withProcessorParameters(ProcessorParameters processorParameters)
public GroupedTableOperationRepartitionNode<K,V> build()