org.apache.flink.table.planner.delegation.hive

Class HiveParser

java.lang.Object

org.apache.flink.table.planner.delegation.hive.HiveParser

All Implemented Interfaces:

Parser

public class HiveParser
extends Object
implements Parser

A Parser that uses Hive's planner to parse a statement.

Method Summary

Modifier and Type	Method and Description
void	analyzeCreateView(HiveParserCreateViewInfo createViewInfo, HiveParserContext context, HiveParserQueryState queryState)
HiveParserCalcitePlanner	createCalcitePlanner(HiveParserContext context, HiveParserQueryState queryState)
String[]	getCompletionHints(String statement, int cursor) Returns completion hints for the given statement at the given cursor position.
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, RowType inputRowType, LogicalType outputType) 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

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,
                                             RowType inputRowType,
                                             @Nullable
                                             LogicalType outputType)

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

inputRowType - the fields available in the SQL expression

outputType - expected top-level output type if available

Returns:

resolved expression

getCompletionHints

public String[] getCompletionHints(String statement,
                                   int cursor)

Description copied from interface: Parser

Returns completion hints for the given statement at the given cursor position. The completion happens case insensitively.

Specified by:

getCompletionHints in interface Parser

Parameters:

statement - Partial or slightly incorrect SQL statement

cursor - cursor position

Returns:

completion hints that fit at the current cursor position

createCalcitePlanner

public HiveParserCalcitePlanner createCalcitePlanner(HiveParserContext context,
                                                     HiveParserQueryState queryState)
                                              throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

analyzeCreateView

public void analyzeCreateView(HiveParserCreateViewInfo createViewInfo,
                              HiveParserContext context,
                              HiveParserQueryState queryState)
                       throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException