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

Packages that use Column

Package	Description
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.connectors.maxcompute.utils
org.apache.flink.cdc.connectors.mysql.utils
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.oracle.utils
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.postgres.utils
org.apache.flink.cdc.connectors.sqlserver.utils
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.parser
org.apache.flink.cdc.runtime.parser.metadata
org.apache.flink.cdc.runtime.serializer.schema
org.apache.flink.cdc.runtime.typeutils

Uses of Column in org.apache.flink.cdc.common.event

Methods in org.apache.flink.cdc.common.event that return Column

Modifier and Type	Method	Description
Column	AddColumnEvent.ColumnWithPosition.getAddColumn()

Methods in org.apache.flink.cdc.common.event with parameters of type Column

Modifier and Type	Method	Description
static AddColumnEvent.ColumnWithPosition	AddColumnEvent.after(Column addColumn, String existedColumnName)
static AddColumnEvent.ColumnWithPosition	AddColumnEvent.before(Column addColumn, String existedColumnName)
static AddColumnEvent.ColumnWithPosition	AddColumnEvent.first(Column addColumn)
static AddColumnEvent.ColumnWithPosition	AddColumnEvent.last(Column addColumn)

Constructors in org.apache.flink.cdc.common.event with parameters of type Column

Constructor	Description
ColumnWithPosition(Column addColumn)	In the default scenario, we add fields at the end of the column.
ColumnWithPosition(Column addColumn, AddColumnEvent.ColumnPosition position, String existedColumnName)

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

Subclasses of Column in org.apache.flink.cdc.common.schema

Modifier and Type	Class	Description
class	MetadataColumn	Representation of a metadata column.
class	PhysicalColumn	Representation of a physical column.

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

Modifier and Type	Method	Description
abstract Column	Column.copy(String newName)	Returns a copy of the column with a replaced name.
abstract Column	Column.copy(DataType newType)	Returns a copy of the column with a replaced DataType.
Column	MetadataColumn.copy(String newName)
Column	MetadataColumn.copy(DataType newType)
Column	PhysicalColumn.copy(String newName)
Column	PhysicalColumn.copy(DataType newType)

Methods in org.apache.flink.cdc.common.schema that return types with arguments of type Column

Modifier and Type	Method	Description
Optional<Column>	Schema.getColumn(String columnName)	Returns the Column instance for the given column name.
List<Column>	Schema.getColumns()	Returns all Columns of this schema.

Methods in org.apache.flink.cdc.common.schema with parameters of type Column

Modifier and Type	Method	Description
Schema.Builder	Schema.Builder.column(Column column)

Method parameters in org.apache.flink.cdc.common.schema with type arguments of type Column

Modifier and Type	Method	Description
Schema	Schema.copy(List<Column> columns)	Returns a copy of the schema with a replaced list of Column.
Schema.Builder	Schema.Builder.setColumns(List<Column> columns)	Set new columns.

Uses of Column in org.apache.flink.cdc.common.utils

Methods in org.apache.flink.cdc.common.utils that return Column

Modifier and Type	Method	Description
static Column	SchemaUtils.inferWiderColumn(Column lColumn, Column rColumn)	Deprecated. Use getLeastCommonType in SchemaMergingUtils instead.

Methods in org.apache.flink.cdc.common.utils with parameters of type Column

Modifier and Type	Method	Description
static Column	SchemaUtils.inferWiderColumn(Column lColumn, Column rColumn)	Deprecated. Use getLeastCommonType in SchemaMergingUtils instead.

Method parameters in org.apache.flink.cdc.common.utils with type arguments of type Column

Modifier and Type	Method	Description
static List<RecordData.FieldGetter>	SchemaUtils.createFieldGetters(List<Column> columns)	create a list of RecordData.FieldGetter from given Column to get Object from RecordData.

Uses of Column in org.apache.flink.cdc.connectors.maxcompute.utils

Methods in org.apache.flink.cdc.connectors.maxcompute.utils with parameters of type Column

Modifier and Type	Method	Description
static com.aliyun.odps.Column	TypeConvertUtils.toMaxCompute(Column flinkColumn, boolean notNull)

Uses of Column in org.apache.flink.cdc.connectors.mysql.utils

Methods in org.apache.flink.cdc.connectors.mysql.utils that return Column

Modifier and Type	Method	Description
static Column	MySqlSchemaUtils.toColumn(io.debezium.relational.Column column, boolean tinyInt1isBit)

Uses of Column in org.apache.flink.cdc.connectors.oceanbase.sink

Methods in org.apache.flink.cdc.connectors.oceanbase.sink with parameters of type Column

Modifier and Type	Method	Description
static void	OceanBaseUtils.toOceanBaseDataType(Column cdcColumn, boolean isPrimaryKeys, OceanBaseColumn.Builder builder)	Convert CDC data type to OceanBase data type.

Uses of Column in org.apache.flink.cdc.connectors.oracle.utils

Methods in org.apache.flink.cdc.connectors.oracle.utils that return Column

Modifier and Type	Method	Description
static Column	OracleSchemaUtils.toColumn(io.debezium.relational.Column column)

Uses of Column in org.apache.flink.cdc.connectors.paimon.sink

Methods in org.apache.flink.cdc.connectors.paimon.sink with parameters of type Column

Modifier and Type	Method	Description
static org.apache.paimon.types.DataType	SchemaChangeProvider.convertToBlobIfNeeded(Column column, Map<String,String> tableOptions)	Convert CDC VARBINARY/BINARY/VARCHAR/STRING type to Paimon BLOB type if configured.

Uses of Column in org.apache.flink.cdc.connectors.postgres.utils

Methods in org.apache.flink.cdc.connectors.postgres.utils that return Column

Modifier and Type	Method	Description
static Column	PostgresSchemaUtils.toColumn(io.debezium.relational.Column column, io.debezium.connector.postgresql.PostgresConnectorConfig dbzConfig, io.debezium.connector.postgresql.TypeRegistry typeRegistry)

Uses of Column in org.apache.flink.cdc.connectors.sqlserver.utils

Methods in org.apache.flink.cdc.connectors.sqlserver.utils that return Column

Modifier and Type	Method	Description
static Column	SqlServerSchemaUtils.toColumn(io.debezium.relational.Column column)

Uses of Column in org.apache.flink.cdc.connectors.starrocks.sink

Methods in org.apache.flink.cdc.connectors.starrocks.sink with parameters of type Column

Modifier and Type	Method	Description
static void	StarRocksUtils.toStarRocksDataType(Column cdcColumn, boolean isPrimaryKeys, com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder)
static void	StarRocksUtils.toStarRocksDataType(Column cdcColumn, boolean isPrimaryKeys, com.starrocks.connector.flink.catalog.StarRocksColumn.Builder builder, int unicodeCharMaxBytes)

Uses of Column in org.apache.flink.cdc.runtime.operators.transform

Methods in org.apache.flink.cdc.runtime.operators.transform that return Column

Modifier and Type	Method	Description
Column	ProjectionColumn.getColumn()

Methods in org.apache.flink.cdc.runtime.operators.transform with parameters of type Column

Modifier and Type	Method	Description
static ProjectionColumn	ProjectionColumn.ofAliased(Column column, String newName, String mappedColumnName)	This projection is created with a simple $id$ AS $new_id$ expression.
static ProjectionColumn	ProjectionColumn.ofForwarded(Column column, String mappedColumnName)	This projection is created with a plain column name.

Method parameters in org.apache.flink.cdc.runtime.operators.transform with type arguments of type Column

Modifier and Type	Method	Description
void	PreTransformOperator.processProjectionTransform(TableId tableId, Schema tableSchema, LinkedHashSet<Column> referencedColumnsSet, PreTransformer transform)

Constructors in org.apache.flink.cdc.runtime.operators.transform with parameters of type Column

Constructor	Description
ProjectionColumn(Column column, String expression, String scriptExpression, List<String> originalColumnNames, Map<String,String> columnNameMap)

Uses of Column in org.apache.flink.cdc.runtime.parser

Fields in org.apache.flink.cdc.runtime.parser with type parameters of type Column

Modifier and Type	Field	Description
List<Column>	JaninoCompiler.Context.columns

Methods in org.apache.flink.cdc.runtime.parser that return types with arguments of type Column

Modifier and Type	Method	Description
static List<Column>	TransformParser.generateReferencedColumns(String projectionExpression, String filterExpression, List<Column> columns)

Method parameters in org.apache.flink.cdc.runtime.parser with type arguments of type Column

Modifier and Type	Method	Description
static DataType	TransformParser.deduceSubExpressionType(List<Column> columns, org.apache.calcite.sql.SqlNode subExpression, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
static DataType	TransformParser.deduceSubExpressionType(List<Column> columns, org.apache.calcite.sql.SqlNode subExpression, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static List<ProjectionColumn>	TransformParser.generateProjectionColumns(String projectionExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
static List<ProjectionColumn>	TransformParser.generateProjectionColumns(String projectionExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static List<Column>	TransformParser.generateReferencedColumns(String projectionExpression, String filterExpression, List<Column> columns)
static JaninoCompiler.Context	JaninoCompiler.Context.of(List<Column> columns, Map<String,String> columnNameMap, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
static JaninoCompiler.Context	JaninoCompiler.Context.of(List<Column> columns, Map<String,String> columnNameMap, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static ProjectionColumn	TransformParser.resolveProjectionColumnFromIdentifier(org.apache.calcite.rel.type.RelDataType relDataType, Map<String,Column> originalColumnMap, String identifier, String projectedColumnName, SupportedMetadataColumn[] supportedMetadataColumns)	Create a projection column from a simple identifier node (could be an upstream physical column or a metadata column).
static String	TransformParser.translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap)
static String	TransformParser.translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap, DecimalPrecisionMode decimalPrecisionMode)

Uses of Column in org.apache.flink.cdc.runtime.parser.metadata

Constructor parameters in org.apache.flink.cdc.runtime.parser.metadata with type arguments of type Column

Constructor	Description
TransformTable(String name, List<Column> columns)

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

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

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

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

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

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

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

Uses of Column in org.apache.flink.cdc.runtime.typeutils

Method parameters in org.apache.flink.cdc.runtime.typeutils with type arguments of type Column

Modifier and Type	Method	Description
static org.apache.calcite.rel.type.RelDataType	CalciteDataTypeConverter.convertCalciteRelDataType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, List<Column> columns)