Skip to content

StreamSource

StreamSource is a SourceStep that builds a KStream (Kafka Streams).

Creating Instance

StreamSource takes the following to be created:

  • ExecutionStepPropertiesV1
  • Topic Name
  • Formats
  • TimestampColumn
  • LogicalSchema
  • Pseudo Column Version

StreamSource is created when:

Building KStreamHolder

KStreamHolder<GenericKey> build(
  PlanBuilder builder,
  PlanInfo info)

build is part of the ExecutionStep abstraction.


build requests the given PlanBuilder to visit this StreamSource.

extractPlanInfo

PlanInfo extractPlanInfo(
  PlanInfoExtractor extractor)

extractPlanInfo is part of the ExecutionStep abstraction.


extractPlanInfo requests the given PlanInfoExtractor to visitStreamSource (with this StreamSource).