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

Class Summary

Class	Description
MongoDBConnectorSourceConnector	SourceConnector uses MongoDBConnectorSourceTask.
MongoDBConnectorSourceTask	Source Task that proxies mongodb kafka connector's MongoSourceTask to adapt to DebeziumChangeFetcher.
MongoDBEnvelope	An immutable descriptor for the structure of ChangeStreamDocument envelopes.