SourceAccumulator¶

SourceAccumulator is a SqlBaseBaseVisitor to collect source relations (possibly aliased) in a SQL query.

aliasedRelation
    : relationPrimary (AS? sourceName)?
    ;

relationPrimary
    : sourceName                        #tableName
    ;

Note

SqlBaseBaseVisitor is generated from io/confluent/ksql/parser/SqlBase.g4 at build time by ANTLR.

visitCreateStream¶