SourceStep¶
SourceStep<K> is an extension of the ExecutionStep abstraction for source execution steps.
Implementations¶
- StreamSource
TableSourceTableSourceV1WindowedStreamSourceWindowedTableSource
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.