org.apache.flink.table.planner.delegation

Class ParserImpl

java.lang.Object

org.apache.flink.table.planner.delegation.ParserImpl

All Implemented Interfaces:

Parser

public class ParserImpl
extends Object
implements Parser

Implementation of Parser that uses Calcite.

Constructor Summary

Constructors

Constructor and Description
ParserImpl(CatalogManager catalogManager, java.util.function.Supplier<org.apache.flink.table.planner.calcite.FlinkPlannerImpl> validatorSupplier, java.util.function.Supplier<CalciteParser> calciteParserSupplier, java.util.function.Function<TableSchema,SqlExprToRexConverter> sqlExprToRexConverterCreator)

Method Summary

Modifier and Type	Method and Description
List<Operation>	parse(String statement) Entry point for parsing SQL queries expressed as a String.
UnresolvedIdentifier	parseIdentifier(String identifier) Entry point for parsing SQL identifiers expressed as a String.
ResolvedExpression	parseSqlExpression(String sqlExpression, TableSchema inputSchema) Entry point for parsing SQL expressions expressed as a String.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParserImpl

public ParserImpl(CatalogManager catalogManager,
                  java.util.function.Supplier<org.apache.flink.table.planner.calcite.FlinkPlannerImpl> validatorSupplier,
                  java.util.function.Supplier<CalciteParser> calciteParserSupplier,
                  java.util.function.Function<TableSchema,SqlExprToRexConverter> sqlExprToRexConverterCreator)

Method Detail

parse

public List<Operation> parse(String statement)

Description copied from interface: Parser

Entry point for parsing SQL queries expressed as a String.

Note:If the created Operation is a QueryOperation it must be in a form that will be understood by the Planner.translate(List) method.

The produced Operation trees should already be validated.

Specified by:

parse in interface Parser

Parameters:

statement - the SQL statement to evaluate

Returns:

parsed queries as trees of relational Operations

parseIdentifier

public UnresolvedIdentifier parseIdentifier(String identifier)

Description copied from interface: Parser

Entry point for parsing SQL identifiers expressed as a String.

Specified by:

parseIdentifier in interface Parser

Parameters:

identifier - the SQL identifier to parse

Returns:

parsed identifier

parseSqlExpression

public ResolvedExpression parseSqlExpression(String sqlExpression,
                                             TableSchema inputSchema)

Description copied from interface: Parser

Entry point for parsing SQL expressions expressed as a String.

Specified by:

parseSqlExpression in interface Parser

Parameters:

sqlExpression - the SQL expression to parse

inputSchema - the schema of the fields in sql expression

Returns:

resolved expression