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:

• ExecutionStepFactory is requested for a StreamSource

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).