CreateStreamCommand¶

CreateStreamCommand is a CreateSourceCommand.

Creating Instance¶

CreateStreamCommand takes the following to be created:

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

CreateStreamCommand is created when:

• CreateSourceFactory is requested to create a CreateStreamCommand

Executing Command¶

DdlCommandResult execute(
  Executor executor)

execute is part of the DdlCommand abstraction.

execute requests the given Executor to execute this CreateStreamCommand.