TableSource¶

TableSource is a SourceStep of KTableHolder of GenericKeys.

Creating Instance¶

TableSource takes the following to be created:

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

TableSource is created when:

• ExecutionStepFactory is requested for a TableSource

Building KTableHolder¶

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

build is part of the ExecutionStep abstraction.

build requests the given PlanBuilder to visit this TableSource.