Package org.apache.kafka.streams.kstream.internals

Class InternalStreamsBuilder

java.lang.Object

org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder

All Implemented Interfaces:

InternalNameProvider

public class InternalStreamsBuilder
extends Object
implements InternalNameProvider

Field Summary

Fields

Modifier and Type	Field	Description
protected StreamsGraphNode	root

Constructor Summary

Constructors

Constructor	Description
InternalStreamsBuilder(InternalTopologyBuilder internalTopologyBuilder)

Method Summary

Modifier and Type	Method	Description
<K,V> void	addGlobalStore(StoreBuilder<?> storeBuilder, String sourceName, String topic, ConsumedInternal<K,V> consumed, String processorName, ProcessorSupplier<K,V> stateUpdateSupplier)
<K,V> void	addGlobalStore(StoreBuilder<?> storeBuilder, String topic, ConsumedInternal<K,V> consumed, ProcessorSupplier<K,V> stateUpdateSupplier)
void	addStateStore(StoreBuilder<?> builder)
void	buildAndOptimizeTopology()
void	buildAndOptimizeTopology(Properties props)
<K,V> GlobalKTable<K,V>	globalTable(String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
String	newProcessorName(String prefix)
String	newStoreName(String prefix)
StreamsGraphNode	root()
<K,V> KStream<K,V>	stream(Collection<String> topics, ConsumedInternal<K,V> consumed)
<K,V> KStream<K,V>	stream(Pattern topicPattern, ConsumedInternal<K,V> consumed)
<K,V> KTable<K,V>	table(String topic, ConsumedInternal<K,V> consumed, MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

root

protected final StreamsGraphNode root

Constructor Detail

InternalStreamsBuilder

public InternalStreamsBuilder(InternalTopologyBuilder internalTopologyBuilder)

Method Detail

stream

public <K,V> KStream<K,V> stream(Collection<String> topics,
                                             ConsumedInternal<K,V> consumed)

stream

public <K,V> KStream<K,V> stream(Pattern topicPattern,
                                             ConsumedInternal<K,V> consumed)

table

public <K,V> KTable<K,V> table(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(String topic,
                                                       ConsumedInternal<K,V> consumed,
                                                       MaterializedInternal<K,V,KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

newProcessorName

public String newProcessorName(String prefix)

Specified by:

newProcessorName in interface InternalNameProvider

newStoreName

public String newStoreName(String prefix)

Specified by:

newStoreName in interface InternalNameProvider

addStateStore

public void addStateStore(StoreBuilder<?> builder)

addGlobalStore

public <K,V> void addGlobalStore(StoreBuilder<?> storeBuilder,
                                       String sourceName,
                                       String topic,
                                       ConsumedInternal<K,V> consumed,
                                       String processorName,
                                       ProcessorSupplier<K,V> stateUpdateSupplier)

addGlobalStore

public <K,V> void addGlobalStore(StoreBuilder<?> storeBuilder,
                                       String topic,
                                       ConsumedInternal<K,V> consumed,
                                       ProcessorSupplier<K,V> stateUpdateSupplier)

buildAndOptimizeTopology

public void buildAndOptimizeTopology()

buildAndOptimizeTopology

public void buildAndOptimizeTopology(Properties props)

root

public StreamsGraphNode root()