Package org.apache.flink.cdc.common.schema

Class PhysicalColumn

java.lang.Object

org.apache.flink.cdc.common.schema.Column

org.apache.flink.cdc.common.schema.PhysicalColumn

All Implemented Interfaces:

Serializable

@PublicEvolving
public class PhysicalColumn
extends Column

Representation of a physical column.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.common.schema.Column

comment, defaultValueExpression, FIELD_FORMAT_NO_DESCRIPTION_NO_DEFAULT_VALUE_EXPRESSION, FIELD_FORMAT_NO_DESCRIPTION_WITH_DEFAULT_VALUE_EXPRESSION, FIELD_FORMAT_WITH_DESCRIPTION_NO_DEFAULT_VALUE_EXPRESSION, FIELD_FORMAT_WITH_DESCRIPTION_WITH_DEFAULT_VALUE_EXPRESSION, name, type

Constructor Summary

Constructors

Constructor	Description
PhysicalColumn(String name, DataType type, String comment)
PhysicalColumn(String name, DataType type, String comment, String defaultValue)

Method Summary

Modifier and Type	Method	Description
Column	copy(String newName)	Returns a copy of the column with a replaced name.
Column	copy(DataType newType)	Returns a copy of the column with a replaced DataType.
boolean	isPhysical()	Returns whether the given column is a physical column of a table or metadata column.

Methods inherited from class org.apache.flink.cdc.common.schema.Column

asSummaryString, equals, getComment, getDefaultValueExpression, getName, getType, hashCode, metadataColumn, metadataColumn, metadataColumn, physicalColumn, physicalColumn, physicalColumn, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

PhysicalColumn

public PhysicalColumn(String name,
                      DataType type,
                      @Nullable
                      String comment)

PhysicalColumn

public PhysicalColumn(String name,
                      DataType type,
                      @Nullable
                      String comment,
                      @Nullable
                      String defaultValue)

Method Detail

isPhysical

public boolean isPhysical()

Description copied from class: Column

Returns whether the given column is a physical column of a table or metadata column.

Specified by:

isPhysical in class Column

copy

public Column copy(DataType newType)

Description copied from class: Column

Returns a copy of the column with a replaced DataType.

Specified by:

copy in class Column

copy

public Column copy(String newName)

Description copied from class: Column

Returns a copy of the column with a replaced name.

Specified by:

copy in class Column