Uses of Class
org.apache.flink.cdc.common.schema.PhysicalColumn

Packages that use PhysicalColumn

Package	Description
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.connectors.iceberg.sink.utils
org.apache.flink.cdc.runtime.serializer.schema

Uses of PhysicalColumn in org.apache.flink.cdc.common.schema

Methods in org.apache.flink.cdc.common.schema that return PhysicalColumn

Modifier and Type	Method	Description
static PhysicalColumn	Column.physicalColumn(String name, DataType type)	Creates a physical column.
static PhysicalColumn	Column.physicalColumn(String name, DataType type, String comment)	Creates a physical column.
static PhysicalColumn	Column.physicalColumn(String name, DataType type, String comment, String defaultValueExpression)	Creates a physical column.

Uses of PhysicalColumn in org.apache.flink.cdc.connectors.iceberg.sink.utils

Methods in org.apache.flink.cdc.connectors.iceberg.sink.utils with parameters of type PhysicalColumn

Modifier and Type	Method	Description
static org.apache.iceberg.types.Types.NestedField	IcebergTypeUtils.convertCdcColumnToIcebergField(int index, PhysicalColumn column)	Convert column from Flink CDC to Iceberg format.

Uses of PhysicalColumn in org.apache.flink.cdc.runtime.serializer.schema

Methods in org.apache.flink.cdc.runtime.serializer.schema that return PhysicalColumn

Modifier and Type	Method	Description
PhysicalColumn	PhysicalColumnSerializer.copy(PhysicalColumn from)
PhysicalColumn	PhysicalColumnSerializer.copy(PhysicalColumn from, PhysicalColumn reuse)
PhysicalColumn	PhysicalColumnSerializer.createInstance()
PhysicalColumn	PhysicalColumnSerializer.deserialize(int version, org.apache.flink.core.memory.DataInputView source)
PhysicalColumn	PhysicalColumnSerializer.deserialize(PhysicalColumn reuse, org.apache.flink.core.memory.DataInputView source)
PhysicalColumn	PhysicalColumnSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.flink.cdc.runtime.serializer.schema that return types with arguments of type PhysicalColumn

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<PhysicalColumn>	PhysicalColumnSerializer.snapshotConfiguration()

Methods in org.apache.flink.cdc.runtime.serializer.schema with parameters of type PhysicalColumn

Modifier and Type	Method	Description
PhysicalColumn	PhysicalColumnSerializer.copy(PhysicalColumn from)
PhysicalColumn	PhysicalColumnSerializer.copy(PhysicalColumn from, PhysicalColumn reuse)
PhysicalColumn	PhysicalColumnSerializer.deserialize(PhysicalColumn reuse, org.apache.flink.core.memory.DataInputView source)
void	PhysicalColumnSerializer.serialize(PhysicalColumn record, org.apache.flink.core.memory.DataOutputView target)