CreateStreamAsSelect¶

CreateStreamAsSelect is a CreateAsSelect that represents CREATE STREAM AS SELECT KSQL command.

Creating Instance¶

CreateStreamAsSelect takes the following to be created:

• NodeLocation
• Source Name
• Query
• notExists flag
• orReplace flag
• CreateSourceAsProperties

CreateStreamAsSelect is created when:

• StatementRewriter.Rewriter is requested to visitCreateStreamAsSelect
• AstBuilder.Visitor is requested to parse CREATE STREAM AS SELECT statement