org.apache.flink.table.planner.operations

Class SqlNodeConvertContext

java.lang.Object

org.apache.flink.table.planner.operations.SqlNodeConvertContext

All Implemented Interfaces:

SqlNodeConverter.ConvertContext

public class SqlNodeConvertContext
extends Object
implements SqlNodeConverter.ConvertContext

An implementation of SqlNodeConverter.ConvertContext.

Constructor Summary

Constructors

Constructor and Description
SqlNodeConvertContext(org.apache.flink.table.planner.calcite.FlinkPlannerImpl flinkPlanner, org.apache.flink.table.catalog.CatalogManager catalogManager)

Method Summary

Modifier and Type	Method and Description
String	expandSqlIdentifiers(String originalSql) Expands identifiers in a given SQL string.
org.apache.flink.table.catalog.CatalogManager	getCatalogManager() Returns the CatalogManager in the convert context.
org.apache.calcite.sql.validate.SqlValidator	getSqlValidator() Returns the SqlValidator in the convert context.
List<org.apache.calcite.rex.RexNode>	reduceRexNodes(List<org.apache.calcite.rex.RexNode> rexNodes) Reduce the given RexNodes.
String	toQuotedSqlString(org.apache.calcite.sql.SqlNode sqlNode) Convert the given into a quoted SQL string.
org.apache.calcite.rel.RelRoot	toRelRoot(org.apache.calcite.sql.SqlNode sqlNode) Converts the given validated SqlNode into a RelRoot.
org.apache.calcite.rex.RexNode	toRexNode(org.apache.calcite.sql.SqlNode sqlNode, org.apache.calcite.rel.type.RelDataType inputRowType, org.apache.flink.table.types.DataType outputType) Converts the given validated SqlNode into a RexNode.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlNodeConvertContext

public SqlNodeConvertContext(org.apache.flink.table.planner.calcite.FlinkPlannerImpl flinkPlanner,
                             org.apache.flink.table.catalog.CatalogManager catalogManager)

Method Detail

getSqlValidator

public org.apache.calcite.sql.validate.SqlValidator getSqlValidator()

Description copied from interface: SqlNodeConverter.ConvertContext

Returns the SqlValidator in the convert context.

Specified by:

getSqlValidator in interface SqlNodeConverter.ConvertContext

getCatalogManager

public org.apache.flink.table.catalog.CatalogManager getCatalogManager()

Description copied from interface: SqlNodeConverter.ConvertContext

Returns the CatalogManager in the convert context.

Specified by:

getCatalogManager in interface SqlNodeConverter.ConvertContext

toRelRoot

public org.apache.calcite.rel.RelRoot toRelRoot(org.apache.calcite.sql.SqlNode sqlNode)

Description copied from interface: SqlNodeConverter.ConvertContext

Converts the given validated SqlNode into a RelRoot.

Specified by:

toRelRoot in interface SqlNodeConverter.ConvertContext

toRexNode

public org.apache.calcite.rex.RexNode toRexNode(org.apache.calcite.sql.SqlNode sqlNode,
                                                org.apache.calcite.rel.type.RelDataType inputRowType,
                                                @Nullable
                                                org.apache.flink.table.types.DataType outputType)

Description copied from interface: SqlNodeConverter.ConvertContext

Converts the given validated SqlNode into a RexNode.

Specified by:

toRexNode in interface SqlNodeConverter.ConvertContext

reduceRexNodes

public List<org.apache.calcite.rex.RexNode> reduceRexNodes(List<org.apache.calcite.rex.RexNode> rexNodes)

Description copied from interface: SqlNodeConverter.ConvertContext

Reduce the given RexNodes.

Specified by:

reduceRexNodes in interface SqlNodeConverter.ConvertContext

toQuotedSqlString

public String toQuotedSqlString(org.apache.calcite.sql.SqlNode sqlNode)

Description copied from interface: SqlNodeConverter.ConvertContext

Convert the given into a quoted SQL string.

Specified by:

toQuotedSqlString in interface SqlNodeConverter.ConvertContext

expandSqlIdentifiers

public String expandSqlIdentifiers(String originalSql)

Description copied from interface: SqlNodeConverter.ConvertContext

Expands identifiers in a given SQL string.

Specified by:

expandSqlIdentifiers in interface SqlNodeConverter.ConvertContext

See Also:

Expander