类的使用
org.apache.flink.cdc.common.schema.Column

使用Column的程序包

程序包	说明
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.utils

org.apache.flink.cdc.common.event中Column的使用

返回Column的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
Column	AddColumnEvent.ColumnWithPosition.getAddColumn()

参数类型为Column的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
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)

参数类型为Column的org.apache.flink.cdc.common.event中的构造器

构造器和说明
ColumnWithPosition(Column addColumn) In the default scenario, we add fields at the end of the column.
ColumnWithPosition(Column addColumn, AddColumnEvent.ColumnPosition position, String existedColumnName)

org.apache.flink.cdc.common.schema中Column的使用

org.apache.flink.cdc.common.schema中Column的子类

限定符和类型	类和说明
class	MetadataColumn Representation of a metadata column.
class	PhysicalColumn Representation of a physical column.

返回Column的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
abstract Column	Column.copy(DataType newType) Returns a copy of the column with a replaced DataType.
Column	MetadataColumn.copy(DataType newType)
Column	PhysicalColumn.copy(DataType newType)
abstract Column	Column.copy(String newName) Returns a copy of the column with a replaced name.
Column	MetadataColumn.copy(String newName)
Column	PhysicalColumn.copy(String newName)

返回变量类型为Column的类型的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
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.

参数类型为Column的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
Schema.Builder	Schema.Builder.column(Column column)

类型变量类型为Column的org.apache.flink.cdc.common.schema中的方法参数

限定符和类型	方法和说明
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.

org.apache.flink.cdc.common.utils中Column的使用

返回Column的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static Column	SchemaUtils.inferWiderColumn(Column lColumn, Column rColumn) 已过时。 Use getLeastCommonType in SchemaMergingUtils instead.

参数类型为Column的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static Column	SchemaUtils.inferWiderColumn(Column lColumn, Column rColumn) 已过时。 Use getLeastCommonType in SchemaMergingUtils instead.

类型变量类型为Column的org.apache.flink.cdc.common.utils中的方法参数

限定符和类型	方法和说明
static List<RecordData.FieldGetter>	SchemaUtils.createFieldGetters(List<Column> columns) create a list of RecordData.FieldGetter from given Column to get Object from RecordData.