org.apache.flink.table.planner.delegation.hive.expressions

Class ExpressionBuilder

java.lang.Object

org.apache.flink.table.planner.delegation.hive.expressions.ExpressionBuilder

public class ExpressionBuilder
extends Object

Most is copied from Flink codebase.

Builder for Expressions.

Constructor Summary

Constructors

Constructor and Description
ExpressionBuilder()

Method Summary

Modifier and Type	Method and Description
static UnresolvedCallExpression	and(Expression arg1, Expression arg2)
static UnresolvedCallExpression	call(FunctionDefinition functionDefinition, Expression... args)
static UnresolvedCallExpression	call(FunctionDefinition functionDefinition, List<Expression> args)
static UnresolvedCallExpression	cast(Expression child, Expression type)
static UnresolvedCallExpression	coalesce(Expression... args)
static UnresolvedCallExpression	concat(Expression input1, Expression input2)
static UnresolvedCallExpression	div(Expression input1, Expression input2)
static UnresolvedCallExpression	equalTo(Expression input1, Expression input2)
static UnresolvedCallExpression	greaterThan(Expression input1, Expression input2)
static UnresolvedCallExpression	hiveAggDecimalPlus(Expression input1, Expression input2) Used only for implementing native hive SUM/AVG aggregations on a Decimal type to avoid overriding decimal precision/scale calculation for sum/avg with the rules applied for the normal plus.
static UnresolvedCallExpression	ifThenElse(Expression condition, Expression ifTrue, Expression ifFalse)
static UnresolvedCallExpression	isNull(Expression input)
static UnresolvedCallExpression	isTrue(Expression input)
static UnresolvedCallExpression	lessThan(Expression input1, Expression input2)
static ValueLiteralExpression	literal(Object value)
static ValueLiteralExpression	literal(Object value, DataType type)
static UnresolvedCallExpression	minus(Expression input1, Expression input2)
static UnresolvedCallExpression	mod(Expression input1, Expression input2)
static UnresolvedCallExpression	not(Expression arg)
static ValueLiteralExpression	nullOf(DataType type)
static UnresolvedCallExpression	or(Expression arg1, Expression arg2)
static UnresolvedCallExpression	plus(Expression input1, Expression input2)
static UnresolvedCallExpression	times(Expression input1, Expression input2)
static UnresolvedCallExpression	tryCast(Expression child, Expression type)
static TypeLiteralExpression	typeLiteral(DataType type)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpressionBuilder

public ExpressionBuilder()

Method Detail

nullOf

public static ValueLiteralExpression nullOf(DataType type)

literal

public static ValueLiteralExpression literal(Object value)

literal

public static ValueLiteralExpression literal(Object value,
                                             DataType type)

call

public static UnresolvedCallExpression call(FunctionDefinition functionDefinition,
                                            Expression... args)

call

public static UnresolvedCallExpression call(FunctionDefinition functionDefinition,
                                            List<Expression> args)

and

public static UnresolvedCallExpression and(Expression arg1,
                                           Expression arg2)

or

public static UnresolvedCallExpression or(Expression arg1,
                                          Expression arg2)

not

public static UnresolvedCallExpression not(Expression arg)

isNull

public static UnresolvedCallExpression isNull(Expression input)

isTrue

public static UnresolvedCallExpression isTrue(Expression input)

coalesce

public static UnresolvedCallExpression coalesce(Expression... args)

ifThenElse

public static UnresolvedCallExpression ifThenElse(Expression condition,
                                                  Expression ifTrue,
                                                  Expression ifFalse)

plus

public static UnresolvedCallExpression plus(Expression input1,
                                            Expression input2)

hiveAggDecimalPlus

@Internal
public static UnresolvedCallExpression hiveAggDecimalPlus(Expression input1,
                                                                    Expression input2)

Used only for implementing native hive SUM/AVG aggregations on a Decimal type to avoid overriding decimal precision/scale calculation for sum/avg with the rules applied for the normal plus.

minus

public static UnresolvedCallExpression minus(Expression input1,
                                             Expression input2)

div

public static UnresolvedCallExpression div(Expression input1,
                                           Expression input2)

times

public static UnresolvedCallExpression times(Expression input1,
                                             Expression input2)

mod

public static UnresolvedCallExpression mod(Expression input1,
                                           Expression input2)

equalTo

public static UnresolvedCallExpression equalTo(Expression input1,
                                               Expression input2)

lessThan

public static UnresolvedCallExpression lessThan(Expression input1,
                                                Expression input2)

greaterThan

public static UnresolvedCallExpression greaterThan(Expression input1,
                                                   Expression input2)

cast

public static UnresolvedCallExpression cast(Expression child,
                                            Expression type)

tryCast

public static UnresolvedCallExpression tryCast(Expression child,
                                               Expression type)

typeLiteral

public static TypeLiteralExpression typeLiteral(DataType type)

concat

public static UnresolvedCallExpression concat(Expression input1,
                                              Expression input2)