org.apache.flink.table.planner.calcite

Class RexFactory

java.lang.Object

org.apache.flink.table.planner.calcite.RexFactory

@Internal
public class RexFactory
extends Object

Planner internal factory for parsing/translating to RexNode.

Constructor Summary

Constructors

Constructor and Description
RexFactory(FlinkTypeFactory typeFactory, Supplier<FlinkPlannerImpl> plannerSupplier, Supplier<org.apache.calcite.sql.SqlDialect> sqlDialectSupplier, Function<FlinkPlannerImpl,FlinkRelBuilder> relBuilderSupplier)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rex.RexNode	convertExpressionToRex(List<org.apache.flink.table.types.logical.RowType.RowField> args, org.apache.flink.table.expressions.Expression expression, org.apache.flink.table.types.logical.LogicalType outputType) Converts Expression to RexNode.
SqlToRexConverter	createSqlToRexConverter(org.apache.calcite.rel.type.RelDataType inputRowType, org.apache.calcite.rel.type.RelDataType outputType) Creates a new instance of SqlToRexConverter to convert SQL expression to RexNode.
SqlToRexConverter	createSqlToRexConverter(org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.LogicalType outputType) Creates a new instance of SqlToRexConverter to convert SQL expression to RexNode.

Methods inherited from class java.lang.Object

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

Constructor Detail

RexFactory

public RexFactory(FlinkTypeFactory typeFactory,
                  Supplier<FlinkPlannerImpl> plannerSupplier,
                  Supplier<org.apache.calcite.sql.SqlDialect> sqlDialectSupplier,
                  Function<FlinkPlannerImpl,FlinkRelBuilder> relBuilderSupplier)

Method Detail

createSqlToRexConverter

public SqlToRexConverter createSqlToRexConverter(org.apache.calcite.rel.type.RelDataType inputRowType,
                                                 @Nullable
                                                 org.apache.calcite.rel.type.RelDataType outputType)

Creates a new instance of SqlToRexConverter to convert SQL expression to RexNode.

createSqlToRexConverter

public SqlToRexConverter createSqlToRexConverter(org.apache.flink.table.types.logical.RowType inputRowType,
                                                 @Nullable
                                                 org.apache.flink.table.types.logical.LogicalType outputType)

Creates a new instance of SqlToRexConverter to convert SQL expression to RexNode.

convertExpressionToRex

public org.apache.calcite.rex.RexNode convertExpressionToRex(List<org.apache.flink.table.types.logical.RowType.RowField> args,
                                                             org.apache.flink.table.expressions.Expression expression,
                                                             @Nullable
                                                             org.apache.flink.table.types.logical.LogicalType outputType)

Converts Expression to RexNode.