Package org.apache.flink.cdc.connectors.mongodb.table

Class MongoDBConnectorFullChangelogDeserializationSchema

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema

org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorFullChangelogDeserializationSchema

All Implemented Interfaces:

Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>, DebeziumDeserializationSchema<org.apache.flink.table.data.RowData>

@PublicEvolving
public class MongoDBConnectorFullChangelogDeserializationSchema
extends MongoDBConnectorDeserializationSchema

Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data that produces full changelog mode structure RowData.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema

hasMetadata, physicalConverter

Constructor Summary

Constructors

Constructor	Description
MongoDBConnectorFullChangelogDeserializationSchema(org.apache.flink.table.types.logical.RowType physicalDataType, MetadataConverter[] metadataConverters, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo, java.time.ZoneId localTimeZone)

Method Summary

Modifier and Type	Method	Description
void	deserialize(org.apache.kafka.connect.source.SourceRecord record, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Deserialize the Debezium record, it is represented in Kafka SourceRecord.

Methods inherited from class org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema

emit, extractBsonDocument, extractRowData, getProducedType, operationTypeFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MongoDBConnectorFullChangelogDeserializationSchema

public MongoDBConnectorFullChangelogDeserializationSchema(org.apache.flink.table.types.logical.RowType physicalDataType,
                                                          MetadataConverter[] metadataConverters,
                                                          org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo,
                                                          java.time.ZoneId localTimeZone)

Method Detail

deserialize

public void deserialize(org.apache.kafka.connect.source.SourceRecord record,
                        org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                 throws Exception

Description copied from interface: DebeziumDeserializationSchema

Deserialize the Debezium record, it is represented in Kafka SourceRecord.

Specified by:

deserialize in interface DebeziumDeserializationSchema<org.apache.flink.table.data.RowData>

Overrides:

deserialize in class MongoDBConnectorDeserializationSchema

Throws:

Exception