Package org.apache.kafka.streams.processor.internals

Class InternalTopologyBuilder

java.lang.Object

org.apache.kafka.streams.processor.internals.InternalTopologyBuilder

public class InternalTopologyBuilder
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	InternalTopologyBuilder.AbstractNode
static class	InternalTopologyBuilder.GlobalStore
static class	InternalTopologyBuilder.Processor
static class	InternalTopologyBuilder.Sink<K,V>
static class	InternalTopologyBuilder.Source
static class	InternalTopologyBuilder.StateStoreFactory<S extends StateStore>
static class	InternalTopologyBuilder.Subtopology
static class	InternalTopologyBuilder.TopicsInfo
static class	InternalTopologyBuilder.TopologyDescription

Constructor Summary

Constructors

Constructor	Description
InternalTopologyBuilder()

Method Summary

Modifier and Type	Method	Description
<K,V> void	addGlobalStore(StoreBuilder<?> storeBuilder, String sourceName, TimestampExtractor timestampExtractor, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer, String topic, String processorName, ProcessorSupplier<K,V> stateUpdateSupplier)
void	addInternalTopic(String topicName, InternalTopicProperties internalTopicProperties)
void	addProcessor(String name, ProcessorSupplier<?,?> supplier, String... predecessorNames)
<K,V> void	addSink(String name, String topic, Serializer<K> keySerializer, Serializer<V> valSerializer, StreamPartitioner<? super K,? super V> partitioner, String... predecessorNames)
<K,V> void	addSink(String name, TopicNameExtractor<K,V> topicExtractor, Serializer<K> keySerializer, Serializer<V> valSerializer, StreamPartitioner<? super K,? super V> partitioner, String... predecessorNames)
void	addSource(Topology.AutoOffsetReset offsetReset, String name, TimestampExtractor timestampExtractor, Deserializer<?> keyDeserializer, Deserializer<?> valDeserializer, String... topics)
void	addSource(Topology.AutoOffsetReset offsetReset, String name, TimestampExtractor timestampExtractor, Deserializer<?> keyDeserializer, Deserializer<?> valDeserializer, Pattern topicPattern)
void	addStateStore(StoreBuilder<?> storeBuilder, boolean allowOverride, String... processorNames)
void	addStateStore(StoreBuilder<?> storeBuilder, String... processorNames)
Set<String>	allStateStoreName()
ProcessorTopology	buildGlobalStateTopology()	Builds the topology for any global state stores
ProcessorTopology	buildSubtopology(int topicGroupId)
ProcessorTopology	buildTopology()
void	connectProcessorAndStateStores(String processorName, String... stateStoreNames)
void	connectSourceStoreAndTopic(String sourceStoreName, String topic)
Collection<Set<String>>	copartitionGroups()
void	copartitionSources(Collection<String> sourceNodes)
String	decoratePseudoTopic(String topic)
InternalTopologyBuilder.TopologyDescription	describe()
Pattern	earliestResetTopicsPattern()
Map<String,String>	getChangelogTopicToStore()
Map<String,StateStore>	globalStateStores()	Get any global StateStores that are part of the topology
boolean	hasNoNonGlobalTopology()
Pattern	latestResetTopicsPattern()
void	maybeUpdateCopartitionSourceGroups(String replacedNodeName, String optimizedNodeName)
Map<Integer,Set<String>>	nodeGroups()
Map<String,List<String>>	nodeToSourceTopics()
InternalTopologyBuilder	rewriteTopology(StreamsConfig config)
InternalTopologyBuilder	setApplicationIdAndInternalStream(String applicationId, String internalStream, String internalStreamCompacted)
void	setDefaultStream(String defaultStream)
Set<String>	sourceTopicNames()
Collection<String>	sourceTopicsForStore(String storeName)
Map<String,List<String>>	stateStoreNameToSourceTopics()
Map<String,InternalTopologyBuilder.StateStoreFactory<?>>	stateStores()
Map<Integer,InternalTopologyBuilder.TopicsInfo>	topicGroups()	Returns the map of topic groups keyed by the group id.
void	validateCopartition()

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalTopologyBuilder

public InternalTopologyBuilder()

Method Detail

setApplicationIdAndInternalStream

public final InternalTopologyBuilder setApplicationIdAndInternalStream(String applicationId,
                                                                       String internalStream,
                                                                       String internalStreamCompacted)

rewriteTopology

public final InternalTopologyBuilder rewriteTopology(StreamsConfig config)

setDefaultStream

public final void setDefaultStream(String defaultStream)

addSource

public final void addSource(Topology.AutoOffsetReset offsetReset,
                            String name,
                            TimestampExtractor timestampExtractor,
                            Deserializer<?> keyDeserializer,
                            Deserializer<?> valDeserializer,
                            String... topics)

addSource

public final void addSource(Topology.AutoOffsetReset offsetReset,
                            String name,
                            TimestampExtractor timestampExtractor,
                            Deserializer<?> keyDeserializer,
                            Deserializer<?> valDeserializer,
                            Pattern topicPattern)

addSink

public final <K,V> void addSink(String name,
                                      String topic,
                                      Serializer<K> keySerializer,
                                      Serializer<V> valSerializer,
                                      StreamPartitioner<? super K,? super V> partitioner,
                                      String... predecessorNames)

addSink

public final <K,V> void addSink(String name,
                                      TopicNameExtractor<K,V> topicExtractor,
                                      Serializer<K> keySerializer,
                                      Serializer<V> valSerializer,
                                      StreamPartitioner<? super K,? super V> partitioner,
                                      String... predecessorNames)

addProcessor

public final void addProcessor(String name,
                               ProcessorSupplier<?,?> supplier,
                               String... predecessorNames)

addStateStore

public final void addStateStore(StoreBuilder<?> storeBuilder,
                                String... processorNames)

addStateStore

public final void addStateStore(StoreBuilder<?> storeBuilder,
                                boolean allowOverride,
                                String... processorNames)

addGlobalStore

public final <K,V> void addGlobalStore(StoreBuilder<?> storeBuilder,
                                             String sourceName,
                                             TimestampExtractor timestampExtractor,
                                             Deserializer<K> keyDeserializer,
                                             Deserializer<V> valueDeserializer,
                                             String topic,
                                             String processorName,
                                             ProcessorSupplier<K,V> stateUpdateSupplier)

connectProcessorAndStateStores

public final void connectProcessorAndStateStores(String processorName,
                                                 String... stateStoreNames)

getChangelogTopicToStore

public Map<String,String> getChangelogTopicToStore()

connectSourceStoreAndTopic

public void connectSourceStoreAndTopic(String sourceStoreName,
                                       String topic)

addInternalTopic

public final void addInternalTopic(String topicName,
                                   InternalTopicProperties internalTopicProperties)

copartitionSources

public final void copartitionSources(Collection<String> sourceNodes)

maybeUpdateCopartitionSourceGroups

public final void maybeUpdateCopartitionSourceGroups(String replacedNodeName,
                                                     String optimizedNodeName)

validateCopartition

public void validateCopartition()

nodeGroups

public Map<Integer,Set<String>> nodeGroups()

buildTopology

public ProcessorTopology buildTopology()

Returns:

the full topology minus any global state

buildSubtopology

public ProcessorTopology buildSubtopology(int topicGroupId)

Parameters:

topicGroupId - group of topics corresponding to a single subtopology

Returns:

subset of the full topology

buildGlobalStateTopology

public ProcessorTopology buildGlobalStateTopology()

Builds the topology for any global state stores

Returns:

ProcessorTopology of global state

globalStateStores

public Map<String,StateStore> globalStateStores()

Get any global StateStores that are part of the topology

Returns:

map containing all global StateStores

allStateStoreName

public Set<String> allStateStoreName()

topicGroups

public Map<Integer,InternalTopologyBuilder.TopicsInfo> topicGroups()

Returns the map of topic groups keyed by the group id. A topic group is a group of topics in the same task.

Returns:

groups of topic names

nodeToSourceTopics

public Map<String,List<String>> nodeToSourceTopics()

earliestResetTopicsPattern

public Pattern earliestResetTopicsPattern()

latestResetTopicsPattern

public Pattern latestResetTopicsPattern()

stateStoreNameToSourceTopics

public Map<String,List<String>> stateStoreNameToSourceTopics()

sourceTopicsForStore

public Collection<String> sourceTopicsForStore(String storeName)

copartitionGroups

public Collection<Set<String>> copartitionGroups()

decoratePseudoTopic

public String decoratePseudoTopic(String topic)

hasNoNonGlobalTopology

public boolean hasNoNonGlobalTopology()

describe

public InternalTopologyBuilder.TopologyDescription describe()

sourceTopicNames

public Set<String> sourceTopicNames()

stateStores

public Map<String,InternalTopologyBuilder.StateStoreFactory<?>> stateStores()