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