Package org.apache.paimon.flink.action.cdc.mongodb

Class Summary

Class	Description
MongoDBActionUtils	Utility class for MongoDB-related actions.
MongoDBCdcTimestampExtractor	Timestamp extractor for MongoDB sources in CDC applications.
MongoDBRecordParser	A parser for MongoDB Debezium JSON records, converting them into a list of RichCdcMultiplexRecords.
MongodbSchemaUtils	Build schema from a MongoDB collection.
MongoDBSyncDatabaseAction	An action class responsible for synchronizing MongoDB databases with a target system.
MongoDBSyncDatabaseActionFactory	Factory to create MongoDBSyncDatabaseAction.
MongoDBSyncTableAction	Represents an action to synchronize a specific MongoDB table with a target system.
MongoDBSyncTableActionFactory	Factory to create MongoDBSyncTableAction.

Enum Summary

Enum	Description
SchemaAcquisitionMode	Enum representing the modes of schema acquisition.