Skip to content


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


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.