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

Class GroupedTableOperationRepartitionNode.GroupedTableOperationRepartitionNodeBuilder<K,V>

java.lang.Object

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

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 BaseRepartitionNode.BaseRepartitionNodeBuilder<K,V,GroupedTableOperationRepartitionNode<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
GroupedTableOperationRepartitionNodeBuilder()

Method Summary

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

GroupedTableOperationRepartitionNodeBuilder

public GroupedTableOperationRepartitionNodeBuilder()

Method Detail

build

public GroupedTableOperationRepartitionNode<K,V> build()

Specified by:

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