Skip to content


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:

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.