public static final class TableSourceNode.TableSourceNodeBuilder<K,V,S extends StateStore>
extends java.lang.Object
Modifier and Type | Method and 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) |
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withSourceName(java.lang.String sourceName)
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withTopic(java.lang.String topic)
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withStoreBuilder(StoreBuilder<S> storeBuilder)
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withConsumedInternal(ConsumedInternal consumedInternal)
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withProcessorParameters(ProcessorParameters<K,V> processorParameters)
public TableSourceNode.TableSourceNodeBuilder<K,V,S> withNodeName(java.lang.String nodeName)
public TableSourceNode.TableSourceNodeBuilder<K,V,S> isGlobalKTable(boolean isGlobaKTable)
public TableSourceNode<K,V,S> build()