Class InternalStreamsBuilder
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder
-
- All Implemented Interfaces:
InternalNameProvider
public class InternalStreamsBuilder extends java.lang.Object implements InternalNameProvider
-
-
Field Summary
Fields Modifier and Type Field Description protected StreamsGraphNode
root
-
Constructor Summary
Constructors Constructor Description InternalStreamsBuilder(InternalTopologyBuilder internalTopologyBuilder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <K,V>
voidaddGlobalStore(StoreBuilder<?> storeBuilder, java.lang.String sourceName, java.lang.String topic, ConsumedInternal<K,V> consumed, java.lang.String processorName, ProcessorSupplier<K,V> stateUpdateSupplier)
<K,V>
voidaddGlobalStore(StoreBuilder<?> storeBuilder, java.lang.String topic, ConsumedInternal<K,V> consumed, ProcessorSupplier<K,V> stateUpdateSupplier)
void
addStateStore(StoreBuilder<?> builder)
void
buildAndOptimizeTopology()
void
buildAndOptimizeTopology(java.util.Properties props)
<K,V>
GlobalKTable<K,V>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>
KTable<K,V>table(java.lang.String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
-
-
-
Field Detail
-
root
protected final StreamsGraphNode root
-
-
Constructor Detail
-
InternalStreamsBuilder
public InternalStreamsBuilder(InternalTopologyBuilder internalTopologyBuilder)
-
-
Method Detail
-
stream
public <K,V> KStream<K,V> stream(java.util.Collection<java.lang.String> topics, ConsumedInternal<K,V> consumed)
-
stream
public <K,V> KStream<K,V> stream(java.util.regex.Pattern topicPattern, ConsumedInternal<K,V> consumed)
-
table
public <K,V> KTable<K,V> table(java.lang.String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
-
globalTable
public <K,V> GlobalKTable<K,V> globalTable(java.lang.String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
-
newProcessorName
public java.lang.String newProcessorName(java.lang.String prefix)
- Specified by:
newProcessorName
in interfaceInternalNameProvider
-
newStoreName
public java.lang.String newStoreName(java.lang.String prefix)
- Specified by:
newStoreName
in interfaceInternalNameProvider
-
addStateStore
public void addStateStore(StoreBuilder<?> builder)
-
addGlobalStore
public <K,V> void addGlobalStore(StoreBuilder<?> storeBuilder, java.lang.String sourceName, java.lang.String topic, ConsumedInternal<K,V> consumed, java.lang.String processorName, ProcessorSupplier<K,V> stateUpdateSupplier)
-
addGlobalStore
public <K,V> void addGlobalStore(StoreBuilder<?> storeBuilder, java.lang.String topic, ConsumedInternal<K,V> consumed, ProcessorSupplier<K,V> stateUpdateSupplier)
-
buildAndOptimizeTopology
public void buildAndOptimizeTopology()
-
buildAndOptimizeTopology
public void buildAndOptimizeTopology(java.util.Properties props)
-
root
public StreamsGraphNode root()
-
-