org.apache.flink.table.calcite

Class CalciteParser

java.lang.Object

org.apache.flink.table.calcite.CalciteParser

public class CalciteParser
extends Object

Thin wrapper around SqlParser that does exception conversion and SqlNode casting.

Constructor Summary

Constructors

Constructor and Description
CalciteParser(org.apache.calcite.sql.parser.SqlParser.Config config)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.sql.SqlNode	parse(String sql) Parses a SQL statement into a SqlNode.
org.apache.calcite.sql.SqlIdentifier	parseIdentifier(String identifier) Parses a SQL string as an identifier into a SqlIdentifier.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CalciteParser

public CalciteParser(org.apache.calcite.sql.parser.SqlParser.Config config)

Method Detail

parse

public org.apache.calcite.sql.SqlNode parse(String sql)

Parses a SQL statement into a SqlNode. The SqlNode is not yet validated.

Parameters:

sql - a sql string to parse

Returns:

a parsed sql node

Throws:

SqlParserException - if an exception is thrown when parsing the statement

parseIdentifier

public org.apache.calcite.sql.SqlIdentifier parseIdentifier(String identifier)

Parses a SQL string as an identifier into a SqlIdentifier.

Parameters:

identifier - a sql string to parse as an identifier

Returns:

a parsed sql node

Throws:

SqlParserException - if an exception is thrown when parsing the identifier