public class SqlExprToRexConverterImpl extends Object implements SqlExprToRexConverter
SqlExprToRexConverter
.Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
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.
|
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)
public String expand(String expr)
SqlExprToRexConverter
E.g. my_udf(f0) + 1
to `my_catalog`.`my_database`.`my_udf`(`f0`) + 1
expand
in interface SqlExprToRexConverter
public org.apache.calcite.rex.RexNode convertToRexNode(String expr)
SqlExprToRexConverter
RexNode
expression.convertToRexNode
in interface SqlExprToRexConverter
expr
- a SQL expression e.g. `my_catalog`.`my_database`.`my_udf`(`f0`) + 1
public org.apache.calcite.rex.RexNode[] convertToRexNodes(String[] exprs)
SqlExprToRexConverter
RexNode
expressions.convertToRexNodes
in interface SqlExprToRexConverter
exprs
- a SQL expression e.g. `my_catalog`.`my_database`.`my_udf`(`f0`) + 1
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.