org.apache.flink.table.client.cli.parser

Class SqlCommandParserImpl

java.lang.Object

org.apache.flink.table.client.cli.parser.SqlCommandParserImpl

All Implemented Interfaces:

SqlCommandParser

public class SqlCommandParserImpl
extends Object
implements SqlCommandParser

The SqlCommandParserImpl uses FlinkSqlParserImplTokenManager to do lexical analysis. It cannot recognize special hive keywords yet because Hive has a slightly different vocabulary compared to Flink's, which causes the SqlCommandParserImpl misunderstanding some Hive's keywords to IDENTIFIER. But the ClientParser is only responsible to check whether the statement is completed or not and only cares about a few statements. So it's acceptable to tolerate the inaccuracy here.

Constructor Summary

Constructors

Constructor and Description
SqlCommandParserImpl()

Method Summary

Modifier and Type	Method and Description
Optional<Command>	parseStatement(String statement) Parses given statement.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlCommandParserImpl

public SqlCommandParserImpl()

Method Detail

parseStatement

public Optional<Command> parseStatement(String statement)
                                 throws SqlExecutionException

Description copied from interface: SqlCommandParser

Parses given statement.

Specified by:

parseStatement in interface SqlCommandParser

Parameters:

statement - the sql client input to evaluate.

Returns:

the optional value of Command parsed. It would be empty when the statement is "" or ";".

Throws:

SqlExecutionException - if any error happen while parsing or validating the statement.