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

Class Summary

Class	Description
MongoDBConnectorDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data structure RowData.
MongoDBConnectorFullChangelogDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data that produces full changelog mode structure RowData.
MongoDBTableSource	A DynamicTableSource that describes how to create a MongoDB change stream events source from a logical description.
MongoDBTableSourceFactory	Factory for creating configured instance of MongoDBTableSource.

Enum Summary

Enum	Description
MongoDBReadableMetadata	Defines the supported metadata columns for MongoDBTableSource.