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(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(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