Skip to content


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:

Executing Command

DdlCommandResult execute(
  Executor executor)

execute is part of the DdlCommand abstraction.

execute requests the given Executor to execute this CreateStreamCommand.