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

Packages that use Schema

Package	Description
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.connectors.doris.sink
org.apache.flink.cdc.connectors.doris.utils
org.apache.flink.cdc.connectors.elasticsearch.serializer
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.fluss.source
org.apache.flink.cdc.connectors.fluss.utils
org.apache.flink.cdc.connectors.hudi.sink.event
org.apache.flink.cdc.connectors.hudi.sink.util
org.apache.flink.cdc.connectors.iceberg.sink.utils
org.apache.flink.cdc.connectors.iceberg.sink.v2
org.apache.flink.cdc.connectors.kafka.json
org.apache.flink.cdc.connectors.kafka.json.debezium
org.apache.flink.cdc.connectors.kafka.json.utils
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.maxcompute.utils
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.utils
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.utils
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.paimon.sink.v2
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.utils
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.utils
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.common.event
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.distributed.event
org.apache.flink.cdc.runtime.operators.schema.regular
org.apache.flink.cdc.runtime.operators.schema.regular.event
org.apache.flink.cdc.runtime.operators.sink
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.operators.transform.exceptions
org.apache.flink.cdc.runtime.serializer.schema
org.apache.flink.cdc.runtime.typeutils

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

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

Modifier and Type	Method	Description
Schema	CreateTableEvent.getSchema()	Returns the table schema.

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

Modifier and Type	Method	Description
void	AlterColumnTypeEvent.fillPreSchema(Schema oldTypeSchema)
void	SchemaChangeEventWithPreSchema.fillPreSchema(Schema oldSchema)	Append schema before change info to this event.

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

Constructor	Description
CreateTableEvent(TableId tableId, Schema schema)

Uses of Schema in org.apache.flink.cdc.common.function

Methods in org.apache.flink.cdc.common.function with parameters of type Schema

Modifier and Type	Method	Description
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.

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

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

Modifier and Type	Method	Description
Schema	Schema.Builder.build()	Returns an instance of a Schema.
Schema	Schema.copy(String comment)	Returns a copy of the schema with a replaced comment.
Schema	Schema.copy(List<Column> columns)	Returns a copy of the schema with a replaced list of Column.

Uses of Schema in org.apache.flink.cdc.common.sink

Methods in org.apache.flink.cdc.common.sink that return types with arguments of type Schema

Modifier and Type	Method	Description
Optional<Schema>	ExistingTableSchemaExpansionSupport.getExistingTableSchema(TableId tableId)	Returns the current schema of the target table, or Optional.empty() if the table does not exist.

Methods in org.apache.flink.cdc.common.sink with parameters of type Schema

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	ForwardHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	TableIdHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
DataType	ExistingTableSchemaExpansionSupport.normalizeToTargetDataType(TableId tableId, String columnName, DataType pipelineDataType, Schema existingTargetSchema)	Converts a pipeline type to the canonical CDC representation of the physical type that this applier will create in the existing target table.

Uses of Schema in org.apache.flink.cdc.common.source

Methods in org.apache.flink.cdc.common.source that return Schema

Modifier and Type	Method	Description
Schema	MetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

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

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

Modifier and Type	Method	Description
static Schema	SchemaUtils.applySchemaChangeEvent(Schema schema, SchemaChangeEvent event)	apply SchemaChangeEvent to the old schema and return the schema after changing.
static Schema	SchemaUtils.ensurePkNonNull(Schema schema)
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)	Deprecated. Use getCommonSchema in SchemaMergingUtils instead.
static Schema	SchemaUtils.inferWiderSchema(Schema lSchema, Schema rSchema)	Deprecated. Use getLeastCommonSchema in SchemaMergingUtils instead.

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

Modifier and Type	Method	Description
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	SchemaUtils.ensurePkNonNull(Schema schema)
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)	Deprecated. 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.

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

Modifier and Type	Method	Description
static Schema	SchemaMergingUtils.getCommonSchema(List<Schema> schemas)	Merge compatible schemas.
static Schema	SchemaUtils.inferWiderSchema(List<Schema> schemas)	Deprecated. Use getCommonSchema in SchemaMergingUtils instead.

Uses of Schema in org.apache.flink.cdc.connectors.doris.sink

Methods in org.apache.flink.cdc.connectors.doris.sink with parameters of type Schema

Modifier and Type	Method	Description
Map<String,Object>	DorisEventSerializer.serializerRecord(RecordData recordData, Schema schema)	serializer RecordData to Doris Value.

Uses of Schema in org.apache.flink.cdc.connectors.doris.utils

Methods in org.apache.flink.cdc.connectors.doris.utils with parameters of type Schema

Modifier and Type	Method	Description
static org.apache.flink.api.java.tuple.Tuple2<String,String>	DorisSchemaUtils.getPartitionInfo(Configuration config, Schema schema, TableId tableId)	Get partition info by config.

Uses of Schema in org.apache.flink.cdc.connectors.elasticsearch.serializer

Methods in org.apache.flink.cdc.connectors.elasticsearch.serializer with parameters of type Schema

Modifier and Type	Method	Description
Map<String,Object>	ElasticsearchEventSerializer.serializeRecord(TableId tableId, RecordData recordData, Schema schema, java.time.ZoneId pipelineZoneId)
String	ElasticsearchEventSerializer.tableSharding(TableId tableId, Schema schema, Map<String,Object> valueMap)

Uses of Schema in org.apache.flink.cdc.connectors.fluss.sink

Methods in org.apache.flink.cdc.connectors.fluss.sink that return types with arguments of type Schema

Modifier and Type	Method	Description
Optional<Schema>	FlussMetaDataApplier.getExistingTableSchema(TableId tableId)

Methods in org.apache.flink.cdc.connectors.fluss.sink with parameters of type Schema

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	FlussHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
DataType	FlussMetaDataApplier.normalizeToTargetDataType(TableId tableId, String columnName, DataType pipelineDataType, Schema existingTargetSchema)

Uses of Schema in org.apache.flink.cdc.connectors.fluss.source

Methods in org.apache.flink.cdc.connectors.fluss.source that return Schema

Modifier and Type	Method	Description
Schema	FlussMetadataAccessor.getTableSchema(TableId tableId)

Uses of Schema in org.apache.flink.cdc.connectors.fluss.utils

Methods in org.apache.flink.cdc.connectors.fluss.utils that return Schema

Modifier and Type	Method	Description
static Schema	FlussConversions.toCdcSchema(org.apache.fluss.metadata.Schema flussSchema)	Converts a Fluss schema to a Flink CDC schema.
static Schema	FlussConversions.toCdcSchema(org.apache.fluss.metadata.Schema flussSchema, List<String> partitionKeys)	Converts a Fluss schema to a Flink CDC schema with table partition keys.

Methods in org.apache.flink.cdc.connectors.fluss.utils with parameters of type Schema

Modifier and Type	Method	Description
static Boolean	FlussConversions.sameSchemaIgnoreCommentAndDefaultValue(Schema oldSchema, Schema newSchema)
static org.apache.fluss.metadata.Schema	FlussConversions.toFlussSchema(Schema cdcSchema)
static org.apache.fluss.metadata.TableDescriptor	FlussConversions.toFlussTable(Schema cdcSchema, List<String> bucketKeys, Integer bucketNum, Map<String,String> tableProperties)

Uses of Schema in org.apache.flink.cdc.connectors.hudi.sink.event

Methods in org.apache.flink.cdc.connectors.hudi.sink.event that return Schema

Modifier and Type	Method	Description
Schema	SchemaChangeOperatorEvent.getNewSchema()	Gets the new schema after the change.
Schema	HudiRecordEventSerializer.getSchema(TableId tableId)	Get cached schema for a table.
Schema	TableAwareCorrespondent.SchemaChangeRequest.getSchema()

Methods in org.apache.flink.cdc.connectors.hudi.sink.event with parameters of type Schema

Modifier and Type	Method	Description
boolean	TableAwareCorrespondent.requestSchemaChange(TableId tableId, Schema newSchema)	Send a request to coordinator to apply the schema change.
void	HudiRecordEventSerializer.setSchema(TableId tableId, Schema schema)	Set schema for a table.

Constructors in org.apache.flink.cdc.connectors.hudi.sink.event with parameters of type Schema

Constructor	Description
SchemaChangeOperatorEvent(TableId tableId, Schema newSchema)	Constructs a new SchemaChangeOperatorEvent.
SchemaChangeRequest(TableId tableId, Schema schema)

Uses of Schema in org.apache.flink.cdc.connectors.hudi.sink.util

Methods in org.apache.flink.cdc.connectors.hudi.sink.util with parameters of type Schema

Modifier and Type	Method	Description
static org.apache.hudi.client.model.HoodieFlinkInternalRow	RowDataUtils.convertDataChangeEventToHoodieFlinkInternalRow(DataChangeEvent dataChangeEvent, Schema schema, java.time.ZoneId zoneId, org.apache.hudi.sink.bulk.RowDataKeyGen keyGen, String fileId, String instantTime)	Convert a DataChangeEvent to a HoodieFlinkInternalRow with automatic record key and partition path extraction using Hudi's RowDataKeyGen.
static List<RecordData.FieldGetter>	RowDataUtils.createFieldGetters(Schema schema, java.time.ZoneId zoneId)
static org.apache.hudi.sink.bulk.RowDataKeyGen	RowDataUtils.createKeyGen(Schema schema)	Create a RowDataKeyGen for a table based on its schema.
static org.apache.flink.configuration.Configuration	ConfigUtils.createTableConfig(org.apache.flink.configuration.Configuration baseConfig, Schema cdcSchema, TableId tableId)
static String	RowDataUtils.extractPartitionPathFromDataChangeEvent(DataChangeEvent dataChangeEvent, Schema schema)	Extract partition path from DataChangeEvent based on partition key fields in schema.
static String	RowDataUtils.extractRecordKeyFromDataChangeEvent(DataChangeEvent dataChangeEvent, Schema schema)	Extract record key from DataChangeEvent based on primary key fields in schema.
static void	ConfigUtils.setupHoodieKeyOptions(Map<String,String> tableOptions, Schema schema)	Sets up the hoodie key options (e.g.
static org.apache.flink.table.types.logical.RowType	RowDataUtils.toRowType(Schema schema)	Converts a Flink CDC Schema to a Flink Table RowType.

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

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

Modifier and Type	Method	Description
static List<RecordData.FieldGetter>	IcebergTypeUtils.createFieldGetters(Schema schema, java.time.ZoneId zoneId)

Uses of Schema in org.apache.flink.cdc.connectors.iceberg.sink.v2

Methods in org.apache.flink.cdc.connectors.iceberg.sink.v2 that return Schema

Modifier and Type	Method	Description
Schema	TableSchemaWrapper.getSchema()

Constructors in org.apache.flink.cdc.connectors.iceberg.sink.v2 with parameters of type Schema

Constructor	Description
TableSchemaWrapper(Schema schema, java.time.ZoneId zoneId)

Uses of Schema in org.apache.flink.cdc.connectors.kafka.json

Methods in org.apache.flink.cdc.connectors.kafka.json that return Schema

Modifier and Type	Method	Description
Schema	TableSchemaInfo.getSchema()

Constructors in org.apache.flink.cdc.connectors.kafka.json with parameters of type Schema

Constructor	Description
TableSchemaInfo(TableId tableId, Schema schema, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema, java.time.ZoneId zoneId)

Uses of Schema in org.apache.flink.cdc.connectors.kafka.json.debezium

Methods in org.apache.flink.cdc.connectors.kafka.json.debezium with parameters of type Schema

Modifier and Type	Method	Description
String	DebeziumJsonSerializationSchema.convertSchemaToDebeziumSchema(Schema schema)	convert CDC Schema to Debezium schema.

Uses of Schema in org.apache.flink.cdc.connectors.kafka.json.utils

Methods in org.apache.flink.cdc.connectors.kafka.json.utils with parameters of type Schema

Modifier and Type	Method	Description
static List<RecordData.FieldGetter>	RecordDataConverter.createFieldGetters(Schema schema, java.time.ZoneId zoneId)	Create RecordData.FieldGetters from given CDC Schema.

Uses of Schema in org.apache.flink.cdc.connectors.maxcompute.sink

Methods in org.apache.flink.cdc.connectors.maxcompute.sink with parameters of type Schema

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	MaxComputeHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

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

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

Modifier and Type	Method	Description
static List<RecordData.FieldGetter>	TypeConvertUtils.createFieldGetters(Schema schema)	create a list of RecordData.FieldGetter from given Schema to get Object from RecordData.
static void	SchemaEvolutionUtils.createTable(MaxComputeOptions options, TableId tableId, Schema schema)	equals to run a sql like: create table table_name (col_name1 type1 comment [, col_name2 type2 ...]);.
static com.aliyun.odps.TableSchema	TypeConvertUtils.toMaxCompute(Schema flinkSchema)	this method ignore the message of primary key in flinkSchema.
static void	TypeConvertUtils.toMaxComputeRecord(Schema flinkSchema, RecordData from, com.aliyun.odps.data.ArrayRecord to)

Uses of Schema in org.apache.flink.cdc.connectors.mysql.source

Methods in org.apache.flink.cdc.connectors.mysql.source that return Schema

Modifier and Type	Method	Description
Schema	MySqlMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

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

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

Modifier and Type	Method	Description
static Schema	MySqlSchemaUtils.getTableSchema(io.debezium.connector.mysql.MySqlPartition partition, TableId tableId, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Schema	MySqlSchemaUtils.getTableSchema(MySqlSourceConfig sourceConfig, io.debezium.connector.mysql.MySqlPartition partition, TableId tableId)
static Schema	MySqlSchemaUtils.toSchema(io.debezium.relational.Table table, boolean tinyInt1isBit)

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

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

Modifier and Type	Method	Description
Object[]	OceanBaseEventSerializationSchema.serializerRecord(RecordData recordData, Schema schema)	serializer RecordData to oceanbase data change record.
static OceanBaseTable	OceanBaseUtils.toOceanBaseTable(TableId tableId, Schema schema)	Convert a source table to OceanBaseTable.

Uses of Schema in org.apache.flink.cdc.connectors.oracle.source

Methods in org.apache.flink.cdc.connectors.oracle.source that return Schema

Modifier and Type	Method	Description
Schema	OracleMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

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

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

Modifier and Type	Method	Description
static Schema	OracleSchemaUtils.getSchema(io.debezium.jdbc.JdbcConnection jdbcConnection, io.debezium.relational.TableId tableId)
static Schema	OracleSchemaUtils.getTableSchema(TableId tableId, OracleSourceConfig sourceConfig)
static Schema	OracleSchemaUtils.toSchema(io.debezium.relational.Table table)

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

Methods in org.apache.flink.cdc.connectors.paimon.sink that return types with arguments of type Schema

Modifier and Type	Method	Description
Optional<Schema>	PaimonMetadataApplier.getExistingTableSchema(TableId tableId)

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

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	PaimonHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
DataType	PaimonMetadataApplier.normalizeToTargetDataType(TableId tableId, String columnName, DataType pipelineDataType, Schema existingTargetSchema)

Constructors in org.apache.flink.cdc.connectors.paimon.sink with parameters of type Schema

Constructor	Description
PaimonHashFunction(Schema schema, java.time.ZoneId zoneId, int parallelism)

Uses of Schema in org.apache.flink.cdc.connectors.paimon.sink.v2

Methods in org.apache.flink.cdc.connectors.paimon.sink.v2 that return Schema

Modifier and Type	Method	Description
static Schema	PaimonWriterHelper.deduceSchemaForPaimonTable(org.apache.paimon.table.Table table)	Deduce Schema for a Table.
Schema	TableSchemaInfo.getSchema()

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

Modifier and Type	Method	Description
static List<RecordData.FieldGetter>	PaimonWriterHelper.createFieldGetters(Schema schema, java.time.ZoneId zoneId)	create a list of RecordData.FieldGetter for PaimonWriter.
static List<RecordData.FieldGetter>	PaimonWriterHelper.createFieldGetters(Schema schema, java.time.ZoneId zoneId, BlobWriteContext blobWriteContext)	create a list of RecordData.FieldGetter for PaimonWriter with BLOB support.
static Boolean	PaimonWriterHelper.sameColumnsIgnoreCommentAndDefaultValue(Schema upstreamSchema, Schema physicalSchema)	Check if the columns of upstream schema is the same as the physical schema.

Constructors in org.apache.flink.cdc.connectors.paimon.sink.v2 with parameters of type Schema

Constructor	Description
TableSchemaInfo(Schema schema, java.time.ZoneId zoneId, BlobWriteContext blobWriteContext)

Uses of Schema in org.apache.flink.cdc.connectors.postgres.source

Methods in org.apache.flink.cdc.connectors.postgres.source that return Schema

Modifier and Type	Method	Description
Schema	PostgresMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

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

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

Modifier and Type	Method	Description
static Schema	PostgresSchemaUtils.getTableSchema(io.debezium.relational.TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)
static Schema	PostgresSchemaUtils.getTableSchema(TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)
static Schema	PostgresSchemaUtils.getTableSchema(PostgresSourceConfig sourceConfig, TableId tableId)
static Schema	PostgresSchemaUtils.toSchema(io.debezium.relational.Table table, io.debezium.connector.postgresql.PostgresConnectorConfig dbzConfig, io.debezium.connector.postgresql.TypeRegistry typeRegistry)

Uses of Schema in org.apache.flink.cdc.connectors.sqlserver.source

Methods in org.apache.flink.cdc.connectors.sqlserver.source that return Schema

Modifier and Type	Method	Description
Schema	SqlServerMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

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

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

Modifier and Type	Method	Description
static Schema	SqlServerSchemaUtils.getTableSchema(io.debezium.relational.TableId tableId, io.debezium.connector.sqlserver.SqlServerConnection jdbc, SqlServerDialect dialect)
static Schema	SqlServerSchemaUtils.getTableSchema(TableId tableId, io.debezium.connector.sqlserver.SqlServerConnection jdbc, SqlServerDialect dialect)
static Schema	SqlServerSchemaUtils.getTableSchema(SqlServerSourceConfig sourceConfig, TableId tableId)
static Schema	SqlServerSchemaUtils.toSchema(io.debezium.relational.Table table)

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

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

Modifier and Type	Method	Description
static com.starrocks.connector.flink.catalog.StarRocksTable	StarRocksUtils.toStarRocksTable(TableId tableId, Schema schema, TableCreateConfig tableCreateConfig)	Convert a source table to StarRocksTable.

Uses of Schema in org.apache.flink.cdc.connectors.values

Methods in org.apache.flink.cdc.connectors.values that return Schema

Modifier and Type	Method	Description
static Schema	ValuesDatabase.getTableSchema(TableId tableId)
Schema	ValuesDatabase.ValuesMetadataAccessor.getTableSchema(TableId tableId)

Uses of Schema in org.apache.flink.cdc.runtime.operators.schema.common

Methods in org.apache.flink.cdc.runtime.operators.schema.common that return Schema

Modifier and Type	Method	Description
Schema	SchemaManager.getEvolvedSchema(TableId tableId, int version)	Get schema at the specified version of a table.
Schema	SchemaManager.getOriginalSchema(TableId tableId, int version)	Get schema at the specified version of a table.

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

Modifier and Type	Method	Description
Optional<Schema>	SchemaManager.getLatestEvolvedSchema(TableId tableId)	Get the latest evolved schema of the specified table.
Optional<Schema>	SchemaManager.getLatestOriginalSchema(TableId tableId)	Get the latest original schema of the specified table.
static Set<Schema>	SchemaDerivator.reverseLookupDependingUpstreamSchemas(TableIdRouter tableIdRouter, TableId evolvedTableId, SchemaManager schemaManager)	For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.
static Set<Schema>	SchemaDerivator.reverseLookupDependingUpstreamSchemas(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.

Methods in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type Schema

Modifier and Type	Method	Description
Optional<DataChangeEvent>	SchemaDerivator.coerceDataRecord(String timezone, DataChangeEvent dataChangeEvent, Schema upstreamSchema, Schema evolvedSchema)	Coerce a DataChangeEvent from upstream to expected downstream schema.
void	SchemaRegistry.emplaceEvolvedSchema(TableId tableId, Schema schema)
void	SchemaRegistry.emplaceOriginalSchema(TableId tableId, Schema schema)
static List<SchemaChangeEvent>	SchemaDerivator.normalizeSchemaChangeEvents(Schema oldSchema, List<SchemaChangeEvent> schemaChangeEvents, SchemaChangeBehavior schemaChangeBehavior, MetadataApplier metadataApplier)	Rewrite SchemaChangeEvents by current SchemaChangeBehavior and include / exclude them by fine-grained schema change event configurations.
void	SchemaManager.registerNewEvolvedSchema(TableId tableId, Schema newSchema)
void	SchemaManager.registerNewOriginalSchema(TableId tableId, Schema newSchema)

Method parameters in org.apache.flink.cdc.runtime.operators.schema.common with type arguments of type Schema

Modifier and Type	Method	Description
static Set<Schema>	SchemaDerivator.reverseLookupDependingUpstreamSchemas(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream tables that it depends on.
boolean	SchemaManager.schemaExists(Map<TableId,SortedMap<Integer,Schema>> schemaMap, TableId tableId)

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.common with type arguments of type Schema

Constructor	Description
SchemaManager(Map<TableId,SortedMap<Integer,Schema>> originalSchemas, Map<TableId,SortedMap<Integer,Schema>> evolvedSchemas, SchemaChangeBehavior behavior)

Uses of Schema in org.apache.flink.cdc.runtime.operators.schema.common.event

Methods in org.apache.flink.cdc.runtime.operators.schema.common.event that return types with arguments of type Schema

Modifier and Type	Method	Description
Optional<Schema>	GetEvolvedSchemaResponse.getSchema()
Optional<Schema>	GetOriginalSchemaResponse.getSchema()

Constructors in org.apache.flink.cdc.runtime.operators.schema.common.event with parameters of type Schema

Constructor	Description
GetEvolvedSchemaResponse(Schema schema)
GetOriginalSchemaResponse(Schema schema)

Uses of Schema in org.apache.flink.cdc.runtime.operators.schema.distributed

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed with parameters of type Schema

Modifier and Type	Method	Description
void	SchemaCoordinator.emplaceOriginalSchema(TableId tableId, Integer subTaskId, Schema schema)

Uses of Schema in org.apache.flink.cdc.runtime.operators.schema.distributed.event

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed.event that return types with arguments of type Schema

Modifier and Type	Method	Description
Map<TableId,Schema>	SchemaChangeResponse.getEvolvedSchemas()

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.distributed.event with type arguments of type Schema

Constructor	Description
SchemaChangeResponse(Map<TableId,Schema> evolvedSchemas, List<SchemaChangeEvent> evolvedSchemaChangeEvents)

Uses of Schema in org.apache.flink.cdc.runtime.operators.schema.regular

Methods in org.apache.flink.cdc.runtime.operators.schema.regular with parameters of type Schema

Modifier and Type	Method	Description
void	SchemaOperator.registerInitialSchema(TableId tableId, Schema schema)

Uses of Schema in org.apache.flink.cdc.runtime.operators.schema.regular.event

Methods in org.apache.flink.cdc.runtime.operators.schema.regular.event that return types with arguments of type Schema

Modifier and Type	Method	Description
Map<TableId,Schema>	SchemaChangeResponse.getEvolvedSchemas()

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.regular.event with type arguments of type Schema

Constructor	Description
SchemaChangeResponse(List<SchemaChangeEvent> appliedSchemaChangeEvents, Map<TableId,Schema> evolvedSchemas)

Uses of Schema in org.apache.flink.cdc.runtime.operators.sink

Methods in org.apache.flink.cdc.runtime.operators.sink that return types with arguments of type Schema

Modifier and Type	Method	Description
Optional<Schema>	SchemaEvolutionClient.getLatestEvolvedSchema(TableId tableId)
Optional<Schema>	SchemaEvolutionClient.getLatestOriginalSchema(TableId tableId)

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

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

Modifier and Type	Method	Description
Schema	PostTransformChangeInfo.getPostTransformedSchema()
Schema	PostTransformChangeInfo.getPreTransformedSchema()
Schema	PreTransformChangeInfo.getPreTransformedSchema()
Schema	PreTransformChangeInfo.getSourceSchema()

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

Modifier and Type	Method	Description
static PostTransformChangeInfo	PostTransformChangeInfo.of(TableId tableId, Schema preTransformedSchema, Schema postTransformedSchema)
static PreTransformChangeInfo	PreTransformChangeInfo.of(TableId tableId, Schema sourceSchema, Schema preTransformedSchema)
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 Schema

Constructor	Description
PreTransformChangeInfo(TableId tableId, Schema sourceSchema, Schema preTransformedSchema, RecordData.FieldGetter[] sourceFieldGettersMap, BinaryRecordDataGenerator preTransformedRecordDataGenerator)

Uses of Schema in org.apache.flink.cdc.runtime.operators.transform.exceptions

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

Modifier and Type	Method	Description
static String	TransformException.prettyPrintEvent(Event event, Schema schema)

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

Constructor	Description
TransformException(String command, Event event, TableId tableId, Schema schemaBefore, Schema schemaAfter, Throwable cause)

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

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

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

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

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

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

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

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

Methods in org.apache.flink.cdc.runtime.typeutils with parameters of type Schema

Modifier and Type	Method	Description
static Object	BinaryRecordDataExtractor.extractRecord(RecordData record, Schema schema)	Converts a binary record data with specific schema to Java objects.