org.apache.paimon.flink.action.cdc

Class Expression.TemporalExpressionBase<T>

java.lang.Object

org.apache.paimon.flink.action.cdc.Expression.TemporalExpressionBase<T>

All Implemented Interfaces:

Serializable, Expression

Direct Known Subclasses:

Expression.DateFormat, Expression.TemporalToIntConverter

Enclosing interface:

Expression

public abstract static class Expression.TemporalExpressionBase<T>
extends Object
implements Expression

Expression to handle temporal value.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.flink.action.cdc.Expression

Expression.CastExpression, Expression.DateFormat, Expression.ExpressionCreator, Expression.ExpressionFunction, Expression.ReferencedField, Expression.Substring, Expression.TemporalExpressionBase<T>, Expression.TemporalToIntConverter, Expression.TruncateComputer

Method Summary

Modifier and Type	Method and Description
protected abstract java.util.function.Function<java.time.LocalDateTime,T>	createConverter()
String	eval(String input) Compute value from given input.
String	fieldReference() Return name of referenced field.
DataType	outputType() If not, this must be overridden!

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.action.cdc.Expression

cast, create, substring, truncate

Method Detail

fieldReference

public String fieldReference()

Description copied from interface: Expression

Return name of referenced field.

Specified by:

fieldReference in interface Expression

outputType

public DataType outputType()

If not, this must be overridden!

Specified by:

outputType in interface Expression

eval

public String eval(String input)

Description copied from interface: Expression

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

Specified by:

eval in interface Expression

createConverter

protected abstract java.util.function.Function<java.time.LocalDateTime,T> createConverter()