org.apache.paimon.flink.action.cdc

Class ComputedColumn

java.lang.Object

org.apache.paimon.flink.action.cdc.ComputedColumn

All Implemented Interfaces:

Serializable

public class ComputedColumn
extends Object
implements Serializable

A Computed column's value is computed from input columns. Only expression with at most two inputs (with referenced field at the first) is supported currently.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ComputedColumn(String columnName, Expression expression)

Method Summary

Modifier and Type	Method and Description
String	columnName()
DataType	columnType()
String	eval(String input) Compute column's value from given argument.
String	fieldReference()

Methods inherited from class java.lang.Object

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

Constructor Detail

ComputedColumn

public ComputedColumn(String columnName,
                      Expression expression)

Method Detail

columnName

public String columnName()

columnType

public DataType columnType()

fieldReference

@Nullable
public String fieldReference()

eval

@Nullable
public String eval(@Nullable
                             String input)

Compute column's value from given argument. Return null if input is null.