Skip to content

SourceStep

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

Implementations

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

Back to top