Skip to content


StatementParser is used to parse KSQL statements in the following:

Creating Instance

StatementParser takes the following to be created:

StatementParser is created when:

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: