StatementParser¶

StatementParser is used to parse KSQL statements in the following:

• InteractiveStatementExecutor
• StreamedQueryResource
• WSQueryEndpoint

Creating Instance¶

StatementParser takes the following to be created:

• KsqlExecutionContext

StatementParser is created when:

• KsqlRestApplication is requested to startAsync (and create a WSQueryEndpoint)
• InteractiveStatementExecutor is created
• StreamedQueryResource is created

Parsing KSQL Statement¶

<T extends Statement> PreparedStatement<T> parseSingleStatement(
  String statementString)

parseSingleStatement requests the ksqlEngine to parse the KSQL statement and then to prepare it.

parseSingleStatement throws an IllegalArgumentException if there are more KSQL statements given:

Expected exactly one KSQL statement; found [size] instead

parseSingleStatement is used when:

• InteractiveStatementExecutor is requested to handleStatementWithTerminatedQueries
• StreamedQueryResource is requested to parse a KSQL statement
• WSQueryEndpoint is requested to parse a KSQL statement)