CreateStream¶

CreateStream is a CreateSource and a ExecutableDdlStatement that represents CREATE STREAM and ASSERT STREAM statements.

CreateStream is handled by:

• CommandFactories is used to handleCreateStream
• CreateSourceFactory is used to createStreamCommand
• CommandIdAssigner is requested to getTopicStreamCommandId

Creating Instance¶

CreateStream takes the following to be created:

• NodeLocation
• SourceName
• TableElements
• orReplace flag
• notExists flag
• CreateSourceProperties
• isSource flag

CreateStream is created when:

• AstBuilder.Visitor is requested to parse CREATE STREAM and ASSERT STREAM statements
• CreateStream is requested to copyWith

copyWith¶

CreateSource copyWith(
  TableElements elements,
  CreateSourceProperties properties
)

copyWith is part of the CreateSource abstraction.

copyWith creates a new CreateStream with the given TableElements and CreateSourceProperties.

Planning¶

EngineExecutor is requested to plan CREATE STREAM statements

Execution¶

• DistributingExecutor
• StatementExecutor