Uses of Class
org.apache.flink.cdc.connectors.mongodb.MongoDBSource.Builder

Packages that use MongoDBSource.Builder

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

Uses of MongoDBSource.Builder in org.apache.flink.cdc.connectors.mongodb

Methods in org.apache.flink.cdc.connectors.mongodb that return MongoDBSource.Builder

Modifier and Type	Method	Description
MongoDBSource.Builder<T>	MongoDBSource.Builder.batchSize(int batchSize)	batch.size
static <T> MongoDBSource.Builder<T>	MongoDBSource.builder()	Deprecated.
MongoDBSource.Builder<T>	MongoDBSource.Builder.collectionList(String... collectionList)	Regular expressions that match fully-qualified collection identifiers for collections to be monitored.
MongoDBSource.Builder<T>	MongoDBSource.Builder.connectionOptions(String connectionOptions)	Ampersand (i.e.
MongoDBSource.Builder<T>	MongoDBSource.Builder.copyExisting(boolean copyExisting)	Deprecated. please use startupOptions instead.
MongoDBSource.Builder<T>	MongoDBSource.Builder.copyExistingMaxThreads(int copyExistingMaxThreads)	Deprecated. use initialSnapshottingMaxThreads instead.
MongoDBSource.Builder<T>	MongoDBSource.Builder.copyExistingPipeline(String copyExistingPipeline)	Deprecated. use initialSnapshottingPipeline instead.
MongoDBSource.Builder<T>	MongoDBSource.Builder.copyExistingQueueSize(int copyExistingQueueSize)	Deprecated. use initialSnapshottingQueueSize instead.
MongoDBSource.Builder<T>	MongoDBSource.Builder.databaseList(String... databaseList)	Regular expressions list that match database names to be monitored.
MongoDBSource.Builder<T>	MongoDBSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer)	The deserializer used to convert from consumed SourceRecord.
MongoDBSource.Builder<T>	MongoDBSource.Builder.heartbeatIntervalMillis(int heartbeatIntervalMillis)	heartbeat.interval.ms
MongoDBSource.Builder<T>	MongoDBSource.Builder.hosts(String hosts)	The comma-separated list of hostname and port pairs of mongodb servers.
MongoDBSource.Builder<T>	MongoDBSource.Builder.initialSnapshottingMaxThreads(int initialSnapshottingMaxThreads)	initial.snapshotting.max.threads
MongoDBSource.Builder<T>	MongoDBSource.Builder.initialSnapshottingPipeline(String initialSnapshottingPipeline)	initial.snapshotting.pipeline eg.
MongoDBSource.Builder<T>	MongoDBSource.Builder.initialSnapshottingQueueSize(int initialSnapshottingQueueSize)	initial.snapshotting.queue.size
MongoDBSource.Builder<T>	MongoDBSource.Builder.password(String password)	Password to be used when connecting to MongoDB.
MongoDBSource.Builder<T>	MongoDBSource.Builder.pollAwaitTimeMillis(int pollAwaitTimeMillis)	poll.await.time.ms
MongoDBSource.Builder<T>	MongoDBSource.Builder.pollMaxBatchSize(int pollMaxBatchSize)	poll.max.batch.size
MongoDBSource.Builder<T>	MongoDBSource.Builder.scanFullChangelog(boolean fullDocumentBeforeChange)	change.stream.full.document.before.change
MongoDBSource.Builder<T>	MongoDBSource.Builder.scheme(String scheme)	The protocol connected to MongoDB.
MongoDBSource.Builder<T>	MongoDBSource.Builder.startupOptions(StartupOptions startupOptions)	scan.startup.mode
MongoDBSource.Builder<T>	MongoDBSource.Builder.updateLookup(boolean updateLookup)	change.stream.full.document
MongoDBSource.Builder<T>	MongoDBSource.Builder.username(String username)	Name of the database user to be used when connecting to MongoDB.