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

使用Schema的程序包

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

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

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

限定符和类型	方法和说明
Schema	CreateTableEvent.getSchema() Returns the table schema.

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

限定符和类型	方法和说明
void	SchemaChangeEventWithPreSchema.fillPreSchema(Schema oldSchema) Append schema before change info to this event.
void	AlterColumnTypeEvent.fillPreSchema(Schema oldTypeSchema)

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

构造器和说明
CreateTableEvent(TableId tableId, Schema schema)

org.apache.flink.cdc.common.function中Schema的使用

参数类型为Schema的org.apache.flink.cdc.common.function中的方法

限定符和类型	方法和说明
HashFunction<T>	HashFunctionProvider.getHashFunction(TableId tableId, Schema schema) Gets a hash function based on the given table ID and schema, to help PrePartitionOperator to shuffle DataChangeEvent to designated subtask.

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

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

限定符和类型	方法和说明
Schema	Schema.Builder.build() Returns an instance of a Schema.
Schema	Schema.copy(List<Column> columns) Returns a copy of the schema with a replaced list of Column.

org.apache.flink.cdc.common.sink中Schema的使用

参数类型为Schema的org.apache.flink.cdc.common.sink中的方法

限定符和类型	方法和说明
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

org.apache.flink.cdc.common.source中Schema的使用

返回Schema的org.apache.flink.cdc.common.source中的方法

限定符和类型	方法和说明
Schema	MetadataAccessor.getTableSchema(TableId tableId) Get the Schema of the given table.

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

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

限定符和类型	方法和说明
static Schema	SchemaUtils.applySchemaChangeEvent(Schema schema, SchemaChangeEvent event) apply SchemaChangeEvent to the old schema and return the schema after changing.
static Schema	SchemaMergingUtils.getCommonSchema(List<Schema> schemas) Merge compatible schemas.
static Schema	SchemaMergingUtils.getLeastCommonSchema(Schema currentSchema, Schema upcomingSchema) Try to merge upcomingSchema into currentSchema by performing lenient schema changes.
static Schema	SchemaUtils.inferWiderSchema(List<Schema> schemas) 已过时。 Use getCommonSchema in SchemaMergingUtils instead.
static Schema	SchemaUtils.inferWiderSchema(Schema lSchema, Schema rSchema) 已过时。 Use getLeastCommonSchema in SchemaMergingUtils instead.

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

限定符和类型	方法和说明
static Schema	SchemaUtils.applySchemaChangeEvent(Schema schema, SchemaChangeEvent event) apply SchemaChangeEvent to the old schema and return the schema after changing.
static Object[]	SchemaMergingUtils.coerceRow(String timezone, Schema currentSchema, Schema upcomingSchema, List<Object> upcomingRow) Coercing upcomingRow with upcomingTypes schema into currentTypes schema.
static Object[]	SchemaMergingUtils.coerceRow(String timezone, Schema currentSchema, Schema upcomingSchema, List<Object> upcomingRow, boolean toleranceMode) Coercing upcomingRow with upcomingTypes schema into currentTypes schema.
static List<RecordData.FieldGetter>	SchemaUtils.createFieldGetters(Schema schema) create a list of RecordData.FieldGetter from given Schema to get Object from RecordData.
static Schema	SchemaMergingUtils.getLeastCommonSchema(Schema currentSchema, Schema upcomingSchema) Try to merge upcomingSchema into currentSchema by performing lenient schema changes.
static List<SchemaChangeEvent>	SchemaMergingUtils.getSchemaDifference(TableId tableId, Schema beforeSchema, Schema afterSchema) Generating what schema change events we need to do by converting compatible beforeSchema to afterSchema.
static Schema	SchemaUtils.inferWiderSchema(Schema lSchema, Schema rSchema) 已过时。 Use getLeastCommonSchema in SchemaMergingUtils instead.
static boolean	SchemaUtils.isSchemaChangeEventRedundant(Schema currentSchema, SchemaChangeEvent event) This function checks if the given schema change event has been applied already.
static boolean	SchemaMergingUtils.isSchemaCompatible(Schema currentSchema, Schema upcomingSchema) Checking if given upcomingSchema could be fit into currently known currentSchema.

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

限定符和类型	方法和说明
static Schema	SchemaMergingUtils.getCommonSchema(List<Schema> schemas) Merge compatible schemas.
static Schema	SchemaUtils.inferWiderSchema(List<Schema> schemas) 已过时。 Use getCommonSchema in SchemaMergingUtils instead.