org.apache.paimon.flink.action.cdc

Interface Expression

All Superinterfaces:

Serializable

All Known Implementing Classes:

Expression.CastExpression, Expression.DateFormat, Expression.Substring, Expression.TemporalExpressionBase, Expression.TemporalToIntConverter, Expression.TruncateComputer

public interface Expression
extends Serializable

Produce a computation result for computed column.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Expression.CastExpression Get constant value.
static class	Expression.DateFormat Convert the temporal value to desired formatted string.
static interface	Expression.ExpressionCreator Expression creator.
static class	Expression.ExpressionFunction Expression function.
static class	Expression.ReferencedField Referenced field in expression input parameters.
static class	Expression.Substring Get substring using String.substring(int).
static class	Expression.TemporalExpressionBase<T> Expression to handle temporal value.
static class	Expression.TemporalToIntConverter Convert the temporal value to an integer.
static class	Expression.TruncateComputer Truncate numeric/decimal/string value.

Method Summary

Modifier and Type	Method and Description
static Expression	cast(String... literals)
static Expression	create(Map<String,DataType> typeMapping, boolean caseSensitive, String exprName, String... args)
String	eval(String input) Compute value from given input.
String	fieldReference() Return name of referenced field.
DataType	outputType() Return DataType of computed value.
static Expression	substring(String fieldReference, String... literals)
static Expression	truncate(String fieldReference, DataType fieldType, String... literals)

Method Detail

fieldReference

String fieldReference()

Return name of referenced field.

outputType

DataType outputType()

Return DataType of computed value.

eval

String eval(String input)

Compute value from given input. Input and output are serialized to string.

create

static Expression create(Map<String,DataType> typeMapping,
                         boolean caseSensitive,
                         String exprName,
                         String... args)

substring

static Expression substring(String fieldReference,
                            String... literals)

truncate

static Expression truncate(String fieldReference,
                           DataType fieldType,
                           String... literals)

cast

static Expression cast(String... literals)