org.apache.flink.table.planner.calcite

类 SqlExprToRexConverterImpl

java.lang.Object

org.apache.flink.table.planner.calcite.SqlExprToRexConverterImpl

所有已实现的接口:

SqlExprToRexConverter

public class SqlExprToRexConverterImpl
extends Object
implements SqlExprToRexConverter

Standard implementation of SqlExprToRexConverter.

构造器概要

构造器

构造器和说明
SqlExprToRexConverterImpl(org.apache.calcite.tools.FrameworkConfig config, org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory, org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.sql.SqlDialect sqlDialect, org.apache.calcite.rel.type.RelDataType inputRowType, org.apache.calcite.rel.type.RelDataType outputType)

方法概要

限定符和类型	方法和说明
org.apache.calcite.rex.RexNode	convertToRexNode(String expr) Converts a SQL expression to a RexNode expression.
org.apache.calcite.rex.RexNode[]	convertToRexNodes(String[] exprs) Converts an array of SQL expressions to an array of RexNode expressions.
String	expand(String expr) Converts the given SQL expression string to an expanded string with fully qualified function calls and escaped identifiers.

从类继承的方法 java.lang.Object

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

构造器详细资料

SqlExprToRexConverterImpl

public SqlExprToRexConverterImpl(org.apache.calcite.tools.FrameworkConfig config,
                                 org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
                                 org.apache.calcite.plan.RelOptCluster cluster,
                                 org.apache.calcite.sql.SqlDialect sqlDialect,
                                 org.apache.calcite.rel.type.RelDataType inputRowType,
                                 @Nullable
                                 org.apache.calcite.rel.type.RelDataType outputType)

方法详细资料

expand

public String expand(String expr)

从接口复制的说明: SqlExprToRexConverter

Converts the given SQL expression string to an expanded string with fully qualified function calls and escaped identifiers.

E.g. my_udf(f0) + 1 to `my_catalog`.`my_database`.`my_udf`(`f0`) + 1

指定者:

expand 在接口中 SqlExprToRexConverter

convertToRexNode

public org.apache.calcite.rex.RexNode convertToRexNode(String expr)

从接口复制的说明: SqlExprToRexConverter

Converts a SQL expression to a RexNode expression.

指定者:

convertToRexNode 在接口中 SqlExprToRexConverter

参数:

expr - a SQL expression e.g. `my_catalog`.`my_database`.`my_udf`(`f0`) + 1

convertToRexNodes

public org.apache.calcite.rex.RexNode[] convertToRexNodes(String[] exprs)

从接口复制的说明: SqlExprToRexConverter

Converts an array of SQL expressions to an array of RexNode expressions.

指定者:

convertToRexNodes 在接口中 SqlExprToRexConverter

参数:

exprs - a SQL expression e.g. `my_catalog`.`my_database`.`my_udf`(`f0`) + 1