Skip to content

InternalStreamsBuilder

Creating Instance

InternalStreamsBuilder takes the following to be created:

InternalStreamsBuilder is created when:

Root Node

InternalStreamsBuilder creates a root GraphNode when created.

This root node is used to addGraphNode in the following high-level operators:

This root node is then used to build and optimize a topology (for StreamsBuilder).

buildAndOptimizeTopology

void buildAndOptimizeTopology(
  Properties props)

buildAndOptimizeTopology...FIXME

buildAndOptimizeTopology is used when:

mergeDuplicateSourceNodes

void mergeDuplicateSourceNodes()

mergeDuplicateSourceNodes...FIXME

Adding StateStore to Topology

void addStateStore(
  StoreBuilder<?> builder)

addStateStore adds a new StateStoreNode to the root node.

addStateStore is used when:

  • StreamsBuilder is requested to addStateStore
  • KTableImpl is requested to doJoinOnForeignKey

stream

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

stream...FIXME

stream is used when:

  • StreamsBuilder is requested to stream
Back to top