Skip to content

CreateSourceCommand

CreateSourceCommand is an extension of the DdlCommand abstraction for DDL commands to create sources (streams and tables).

Implementations

Creating Instance

CreateSourceCommand takes the following to be created:

  • SourceName
  • LogicalSchema
  • TimestampColumn
  • Topic Name
  • Formats
  • WindowInfo
  • orReplace flag
  • isSource flag

Abstract Class

CreateSourceCommand is an abstract class and cannot be created directly. It is created indirectly for the concrete CreateSourceCommands.