org.apache.flink.table.planner.expressions

Class DeclarativeExpressionResolver

java.lang.Object

org.apache.flink.table.expressions.ExpressionDefaultVisitor<ResolvedExpression>

org.apache.flink.table.planner.expressions.DeclarativeExpressionResolver

All Implemented Interfaces:

ExpressionVisitor<ResolvedExpression>

public abstract class DeclarativeExpressionResolver
extends ExpressionDefaultVisitor<ResolvedExpression>

Abstract class to resolve the expressions in DeclarativeAggregateFunction.

Constructor Summary

Constructors

Constructor and Description
DeclarativeExpressionResolver(RelBuilder relBuilder, DeclarativeAggregateFunction function, boolean isMerge)

Method Summary

Modifier and Type	Method and Description
protected ResolvedExpression	defaultMethod(Expression expression)
abstract ResolvedExpression	toAccInputExpr(String name, int localIndex) When accumulate phase, for inputs.
abstract ResolvedExpression	toAggBufferExpr(String name, int localIndex) For aggregate buffer.
abstract ResolvedExpression	toMergeInputExpr(String name, int localIndex) When merge phase, for inputs.
static ResolvedExpression	toRexDistinctKey(RelBuilder builder, String name, LogicalType t)
static ResolvedExpression	toRexInputRef(RelBuilder builder, int i, LogicalType t)

Methods inherited from class org.apache.flink.table.expressions.ExpressionDefaultVisitor

visit, visit, visit, visit, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

DeclarativeExpressionResolver

public DeclarativeExpressionResolver(RelBuilder relBuilder,
                                     DeclarativeAggregateFunction function,
                                     boolean isMerge)

Method Detail

defaultMethod

protected ResolvedExpression defaultMethod(Expression expression)

Specified by:

defaultMethod in class ExpressionDefaultVisitor<ResolvedExpression>

toMergeInputExpr

public abstract ResolvedExpression toMergeInputExpr(String name,
                                                    int localIndex)

When merge phase, for inputs.

toAccInputExpr

public abstract ResolvedExpression toAccInputExpr(String name,
                                                  int localIndex)

When accumulate phase, for inputs.

toAggBufferExpr

public abstract ResolvedExpression toAggBufferExpr(String name,
                                                   int localIndex)

For aggregate buffer.

toRexInputRef

public static ResolvedExpression toRexInputRef(RelBuilder builder,
                                               int i,
                                               LogicalType t)

toRexDistinctKey

public static ResolvedExpression toRexDistinctKey(RelBuilder builder,
                                                  String name,
                                                  LogicalType t)