Skip to content


SourceStep<K> is an extension of the ExecutionStep abstraction for source execution steps.


  • StreamSource
  • TableSource
  • TableSourceV1
  • WindowedStreamSource
  • WindowedTableSource

Creating Instance

SourceStep takes the following to be created:

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

Abstract Class

SourceStep is an abstract class and cannot be created directly. It is created indirectly for the concrete SourceSteps.