public class InternalStreamsBuilder extends java.lang.Object implements InternalNameProvider
Modifier and Type | Field and Description |
---|---|
protected StreamsGraphNode |
root |
Constructor and Description |
---|
InternalStreamsBuilder(InternalTopologyBuilder internalTopologyBuilder) |
Modifier and Type | Method and Description |
---|---|
void |
addGlobalStore(StoreBuilder<KeyValueStore> storeBuilder,
java.lang.String topic,
ConsumedInternal consumed,
ProcessorSupplier stateUpdateSupplier) |
void |
addGlobalStore(StoreBuilder<KeyValueStore> storeBuilder,
java.lang.String sourceName,
java.lang.String topic,
ConsumedInternal consumed,
java.lang.String processorName,
ProcessorSupplier stateUpdateSupplier) |
void |
addStateStore(StoreBuilder builder) |
void |
buildAndOptimizeTopology() |
void |
buildAndOptimizeTopology(java.util.Properties props) |
<K,V,S extends StateStore> |
globalTable(java.lang.String topic,
ConsumedInternal<K,V> consumed,
MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized) |
java.lang.String |
newProcessorName(java.lang.String prefix) |
java.lang.String |
newStoreName(java.lang.String prefix) |
StreamsGraphNode |
root() |
<K,V> KStream<K,V> |
stream(java.util.Collection<java.lang.String> topics,
ConsumedInternal<K,V> consumed) |
<K,V> KStream<K,V> |
stream(java.util.regex.Pattern topicPattern,
ConsumedInternal<K,V> consumed) |
<K,V,S extends StateStore> |
table(java.lang.String topic,
ConsumedInternal<K,V> consumed,
MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized) |
protected final StreamsGraphNode root
public InternalStreamsBuilder(InternalTopologyBuilder internalTopologyBuilder)
public <K,V> KStream<K,V> stream(java.util.Collection<java.lang.String> topics, ConsumedInternal<K,V> consumed)
public <K,V> KStream<K,V> stream(java.util.regex.Pattern topicPattern, ConsumedInternal<K,V> consumed)
public <K,V,S extends StateStore> KTable<K,V> table(java.lang.String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
public <K,V,S extends StateStore> GlobalKTable<K,V> globalTable(java.lang.String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
public java.lang.String newProcessorName(java.lang.String prefix)
newProcessorName
in interface InternalNameProvider
public java.lang.String newStoreName(java.lang.String prefix)
newStoreName
in interface InternalNameProvider
public void addStateStore(StoreBuilder builder)
public void addGlobalStore(StoreBuilder<KeyValueStore> storeBuilder, java.lang.String sourceName, java.lang.String topic, ConsumedInternal consumed, java.lang.String processorName, ProcessorSupplier stateUpdateSupplier)
public void addGlobalStore(StoreBuilder<KeyValueStore> storeBuilder, java.lang.String topic, ConsumedInternal consumed, ProcessorSupplier stateUpdateSupplier)
public void buildAndOptimizeTopology()
public void buildAndOptimizeTopology(java.util.Properties props)
public StreamsGraphNode root()