Class TableSourceNode.TableSourceNodeBuilder<K,V,S extends StateStore>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.TableSourceNode.TableSourceNodeBuilder<K,V,S>
-
- Enclosing class:
- TableSourceNode<K,V,S extends StateStore>
public static final class TableSourceNode.TableSourceNodeBuilder<K,V,S extends StateStore> extends java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TableSourceNode<K,V,S>
build()
TableSourceNode.TableSourceNodeBuilder<K,V,S>
isGlobalKTable(boolean isGlobaKTable)
TableSourceNode.TableSourceNodeBuilder<K,V,S>
withConsumedInternal(ConsumedInternal consumedInternal)
TableSourceNode.TableSourceNodeBuilder<K,V,S>
withNodeName(java.lang.String nodeName)
TableSourceNode.TableSourceNodeBuilder<K,V,S>
withProcessorParameters(ProcessorParameters<K,V> processorParameters)
TableSourceNode.TableSourceNodeBuilder<K,V,S>
withSourceName(java.lang.String sourceName)
TableSourceNode.TableSourceNodeBuilder<K,V,S>
withStoreBuilder(StoreBuilder<S> storeBuilder)
TableSourceNode.TableSourceNodeBuilder<K,V,S>
withTopic(java.lang.String topic)
-
-
-
Method Detail
-
withSourceName
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withSourceName(java.lang.String sourceName)
-
withTopic
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withTopic(java.lang.String topic)
-
withStoreBuilder
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withStoreBuilder(StoreBuilder<S> storeBuilder)
-
withConsumedInternal
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withConsumedInternal(ConsumedInternal consumedInternal)
-
withProcessorParameters
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withProcessorParameters(ProcessorParameters<K,V> processorParameters)
-
withNodeName
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withNodeName(java.lang.String nodeName)
-
isGlobalKTable
public TableSourceNode.TableSourceNodeBuilder<K,V,S> isGlobalKTable(boolean isGlobaKTable)
-
build
public TableSourceNode<K,V,S> build()
-
-