Uses of Interface
org.apache.flink.cdc.debezium.DebeziumDeserializationSchema

Packages that use DebeziumDeserializationSchema

Package	Description
org.apache.flink.cdc.connectors.base.source
org.apache.flink.cdc.connectors.base.source.jdbc
org.apache.flink.cdc.connectors.base.source.reader
org.apache.flink.cdc.connectors.db2
org.apache.flink.cdc.connectors.db2.source
org.apache.flink.cdc.connectors.mongodb
org.apache.flink.cdc.connectors.mongodb.source
org.apache.flink.cdc.connectors.mongodb.source.reader
org.apache.flink.cdc.connectors.mongodb.table
org.apache.flink.cdc.connectors.mysql
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.reader
org.apache.flink.cdc.connectors.oracle
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.source.reader
org.apache.flink.cdc.connectors.postgres
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.reader
org.apache.flink.cdc.connectors.sqlserver
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.source.reader
org.apache.flink.cdc.connectors.vitess
org.apache.flink.cdc.debezium
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.debezium.internal
org.apache.flink.cdc.debezium.table

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.base.source

Fields in org.apache.flink.cdc.connectors.base.source declared as DebeziumDeserializationSchema

Modifier and Type	Field	Description
protected DebeziumDeserializationSchema<T>	IncrementalSource.deserializationSchema

Constructors in org.apache.flink.cdc.connectors.base.source with parameters of type DebeziumDeserializationSchema

Constructor	Description
IncrementalSource(SourceConfig.Factory<C> configFactory, DebeziumDeserializationSchema<T> deserializationSchema, OffsetFactory offsetFactory, DataSourceDialect<C> dataSourceDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.base.source.jdbc

Constructors in org.apache.flink.cdc.connectors.base.source.jdbc with parameters of type DebeziumDeserializationSchema

Constructor	Description
JdbcIncrementalSource(JdbcSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, OffsetFactory offsetFactory, JdbcDataSourceDialect dataSourceDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.base.source.reader

Fields in org.apache.flink.cdc.connectors.base.source.reader declared as DebeziumDeserializationSchema

Modifier and Type	Field	Description
protected DebeziumDeserializationSchema<T>	IncrementalSourceRecordEmitter.debeziumDeserializationSchema

Constructors in org.apache.flink.cdc.connectors.base.source.reader with parameters of type DebeziumDeserializationSchema

Constructor	Description
IncrementalSourceRecordEmitter(DebeziumDeserializationSchema<T> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, boolean includeSchemaChanges, OffsetFactory offsetFactory)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.db2

Methods in org.apache.flink.cdc.connectors.db2 with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
Db2Source.Builder<T>	Db2Source.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.db2.source

Methods in org.apache.flink.cdc.connectors.db2.source with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
Db2SourceBuilder<T>	Db2SourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Constructors in org.apache.flink.cdc.connectors.db2.source with parameters of type DebeziumDeserializationSchema

Constructor	Description
Db2IncrementalSource(Db2SourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, LsnFactory offsetFactory, Db2Dialect dataSourceDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.mongodb

Methods in org.apache.flink.cdc.connectors.mongodb with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
MongoDBSource.Builder<T>	MongoDBSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.mongodb.source

Methods in org.apache.flink.cdc.connectors.mongodb.source with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
MongoDBSourceBuilder<T>	MongoDBSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.mongodb.source.reader

Constructors in org.apache.flink.cdc.connectors.mongodb.source.reader with parameters of type DebeziumDeserializationSchema

Constructor	Description
MongoDBRecordEmitter(DebeziumDeserializationSchema<T> deserializationSchema, SourceReaderMetrics sourceReaderMetrics, OffsetFactory offsetFactory)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.mongodb.table

Classes in org.apache.flink.cdc.connectors.mongodb.table that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	MongoDBConnectorDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data structure RowData.
class	MongoDBConnectorFullChangelogDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data that produces full changelog mode structure RowData.

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.mysql

Classes in org.apache.flink.cdc.connectors.mysql that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	SeekBinlogToTimestampFilter<T>	A DebeziumDeserializationSchema which wraps a real DebeziumDeserializationSchema to seek binlog to the specific timestamp.

Methods in org.apache.flink.cdc.connectors.mysql with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
MySqlSource.Builder<T>	MySqlSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	Deprecated. The deserializer used to convert from consumed SourceRecord.

Constructors in org.apache.flink.cdc.connectors.mysql with parameters of type DebeziumDeserializationSchema

Constructor	Description
SeekBinlogToTimestampFilter(long startupTimestampMillis, DebeziumDeserializationSchema<T> serializer)

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

Classes in org.apache.flink.cdc.connectors.mysql.source that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	MySqlEventDeserializer	Event deserializer for MySqlDataSource.

Methods in org.apache.flink.cdc.connectors.mysql.source with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
MySqlSourceBuilder<T>	MySqlSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.mysql.source.reader

Constructors in org.apache.flink.cdc.connectors.mysql.source.reader with parameters of type DebeziumDeserializationSchema

Constructor	Description
MySqlPipelineRecordEmitter(DebeziumDeserializationSchema<Event> debeziumDeserializationSchema, MySqlSourceReaderMetrics sourceReaderMetrics, MySqlSourceConfig sourceConfig, boolean isTableIdCaseInsensitive)
MySqlRecordEmitter(DebeziumDeserializationSchema<T> debeziumDeserializationSchema, MySqlSourceReaderMetrics sourceReaderMetrics, boolean includeSchemaChanges, boolean includeHeartbeatEvents, boolean includeTransactionMetadataEvents)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.oracle

Methods in org.apache.flink.cdc.connectors.oracle with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
OracleSource.Builder<T>	OracleSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

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

Classes in org.apache.flink.cdc.connectors.oracle.source that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	OracleEventDeserializer	Event deserializer for OracleDataSource.

Methods in org.apache.flink.cdc.connectors.oracle.source with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
OracleSourceBuilder<T>	OracleSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Constructors in org.apache.flink.cdc.connectors.oracle.source with parameters of type DebeziumDeserializationSchema

Constructor	Description
OracleIncrementalSource(OracleSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, RedoLogOffsetFactory offsetFactory, OracleDialect dataSourceDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.oracle.source.reader

Constructors in org.apache.flink.cdc.connectors.oracle.source.reader with parameters of type DebeziumDeserializationSchema

Constructor	Description
OraclePipelineRecordEmitter(DebeziumDeserializationSchema<Event> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, boolean includeSchemaChanges, OffsetFactory offsetFactory, OracleSourceConfig sourceConfig)
OracleTableSourceReader(OracleSourceConfigFactory configFactory, DebeziumDeserializationSchema<Event> deserializationSchema, RedoLogOffsetFactory offsetFactory, OracleDialect dataSourceDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.postgres

Methods in org.apache.flink.cdc.connectors.postgres with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
PostgreSQLSource.Builder<T>	PostgreSQLSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

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

Classes in org.apache.flink.cdc.connectors.postgres.source that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	PostgresEventDeserializer	Event deserializer for PostgresDataSource.

Methods in org.apache.flink.cdc.connectors.postgres.source with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
PostgresSourceBuilder<T>	PostgresSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Constructors in org.apache.flink.cdc.connectors.postgres.source with parameters of type DebeziumDeserializationSchema

Constructor	Description
PostgresIncrementalSource(PostgresSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, PostgresOffsetFactory offsetFactory, PostgresDialect dataSourceDialect)
PostgresPipelineSource(PostgresSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, PostgresOffsetFactory offsetFactory, PostgresDialect dataSourceDialect, PostgresSourceConfig sourceConfig)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.postgres.source.reader

Constructors in org.apache.flink.cdc.connectors.postgres.source.reader with parameters of type DebeziumDeserializationSchema

Constructor	Description
PostgresPipelineRecordEmitter(DebeziumDeserializationSchema<T> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, PostgresSourceConfig sourceConfig, OffsetFactory offsetFactory, PostgresDialect postgresDialect)
PostgresSourceRecordEmitter(DebeziumDeserializationSchema<T> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, boolean includeSchemaChanges, OffsetFactory offsetFactory, PostgresSourceConfig sourceConfig)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.sqlserver

Methods in org.apache.flink.cdc.connectors.sqlserver with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
SqlServerSource.Builder<T>	SqlServerSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

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

Classes in org.apache.flink.cdc.connectors.sqlserver.source that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	SqlServerEventDeserializer	Event deserializer for SqlServerDataSource.

Methods in org.apache.flink.cdc.connectors.sqlserver.source with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
SqlServerSourceBuilder<T>	SqlServerSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Constructors in org.apache.flink.cdc.connectors.sqlserver.source with parameters of type DebeziumDeserializationSchema

Constructor	Description
SqlServerIncrementalSource(SqlServerSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, LsnFactory offsetFactory, SqlServerDialect dataSourceDialect)
SqlServerPipelineSource(SqlServerSourceConfigFactory configFactory, DebeziumDeserializationSchema<Event> deserializationSchema, LsnFactory offsetFactory, SqlServerDialect dataSourceDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.sqlserver.source.reader

Constructors in org.apache.flink.cdc.connectors.sqlserver.source.reader with parameters of type DebeziumDeserializationSchema

Constructor	Description
SqlServerPipelineRecordEmitter(DebeziumDeserializationSchema<T> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, SqlServerSourceConfig sourceConfig, OffsetFactory offsetFactory, SqlServerDialect sqlServerDialect)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.connectors.vitess

Methods in org.apache.flink.cdc.connectors.vitess with parameters of type DebeziumDeserializationSchema

Modifier and Type	Method	Description
VitessSource.Builder<T>	VitessSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.debezium

Classes in org.apache.flink.cdc.debezium that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	JsonDebeziumDeserializationSchema	A JSON format implementation of DebeziumDeserializationSchema which deserializes the received SourceRecord to JSON String.
class	StringDebeziumDeserializationSchema	A simple implementation of DebeziumDeserializationSchema which converts the received SourceRecord into String.

Constructors in org.apache.flink.cdc.debezium with parameters of type DebeziumDeserializationSchema

Constructor	Description
DebeziumSourceFunction(DebeziumDeserializationSchema<T> deserializer, Properties properties, DebeziumOffset specificOffset, Validator validator)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.debezium.event

Classes in org.apache.flink.cdc.debezium.event that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	DebeziumEventDeserializationSchema	Debezium event deserializer for SourceRecord.

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.debezium.internal

Constructors in org.apache.flink.cdc.debezium.internal with parameters of type DebeziumDeserializationSchema

Constructor	Description
DebeziumChangeFetcher(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> sourceContext, DebeziumDeserializationSchema<T> deserialization, boolean isInDbSnapshotPhase, String heartbeatTopicPrefix, Handover handover)

Uses of DebeziumDeserializationSchema in org.apache.flink.cdc.debezium.table

Classes in org.apache.flink.cdc.debezium.table that implement DebeziumDeserializationSchema

Modifier and Type	Class	Description
class	RowDataDebeziumDeserializeSchema	Deserialization schema from Debezium object to Flink Table/SQL internal data structure RowData.