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

Class FlinkExtendedParser

java.lang.Object

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

public class FlinkExtendedParser
extends Object

Most code is copied from org.apache.flink.table.planner.parse.ExtendedParser.

FlinkExtendedParser is used for parsing some special command which should be converted to Flink's Operation and follow Flink's behavior.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkExtendedParser.AbstractRegexParseStrategy Strategy to parse statement to Operation by regex.

Constructor Summary

Constructors

Constructor and Description
FlinkExtendedParser()

Method Summary

Modifier and Type	Method and Description
static Optional<Operation>	parseFlinkExtendedCommand(String statement) Convert the statement which matches some special command of Flink to Operation.
static Optional<Operation>	parseSet(String statement) Convert the statement to SetOperation with Flink's parse rule.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkExtendedParser

public FlinkExtendedParser()

Method Detail

parseFlinkExtendedCommand

public static Optional<Operation> parseFlinkExtendedCommand(String statement)

Convert the statement which matches some special command of Flink to Operation.

Returns:

the operation for Flink's extended command, empty for no match Flink's extended command.

parseSet

public static Optional<Operation> parseSet(String statement)

Convert the statement to SetOperation with Flink's parse rule.

Returns:

the SetOperation, empty if the statement is not set command.