MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.assignUnboundedChunkFirst(boolean assignUnboundedChunkFirst) |
Whether the MongoDBSource should assign the unbounded chunks first or not during
snapshot reading phase. |
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.batchSize(int batchSize) |
batch.size
|
static <T> MongoDBSourceBuilder<T> |
MongoDBSource.builder() |
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.closeIdleReaders(boolean closeIdleReaders) |
scan.incremental.close-idle-reader.enabled
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.collectionList(String... collections) |
Regular expressions that match fully-qualified collection identifiers for collections to be
monitored.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.connectionOptions(String connectionOptions) |
Ampersand (i.e.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.databaseList(String... databases) |
Regular expressions list that match database names to be monitored.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.disableCursorTimeout(boolean disableCursorTimeout) |
Whether disable cursor timeout during snapshot phase.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.heartbeatIntervalMillis(int heartbeatIntervalMillis) |
heartbeat.interval.ms
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.hosts(String hosts) |
The comma-separated list of hostname and port pairs of mongodb servers.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.password(String password) |
Password to be used when connecting to MongoDB.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.pollAwaitTimeMillis(int pollAwaitTimeMillis) |
poll.await.time.ms
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.pollMaxBatchSize(int pollMaxBatchSize) |
poll.max.batch.size
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.releaseSnapshotMetadataEnabled(boolean releaseSnapshotMetadataEnabled) |
Whether to release the finished snapshot split metadata from the coordinator after entering
the stream phase, to reduce JobManager memory pressure (FLINK-40697).
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.samplesPerChunk(int samplesPerChunk) |
scan.incremental.snapshot.chunk.samples
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.scanFullChangelog(boolean enableFullDocPrePostImage) |
scan.full-changelog
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.scanNewlyAddedTableEnabled(boolean scanNewlyAddedTableEnabled) |
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.scheme(String scheme) |
The protocol connected to MongoDB.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.skipSnapshotBackfill(boolean skipSnapshotBackfill) |
Whether to skip backfill in snapshot reading phase.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.splitMetaGroupSize(int splitMetaGroupSize) |
The group size of split meta, if the meta size exceeds the group size, the meta will be
divided into multiple groups.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.splitSizeMB(int splitSizeMB) |
scan.incremental.snapshot.chunk.size.mb
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslEnabled(boolean sslEnabled) |
Whether the connector will use SSL to connect to MongoDB instances.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslInvalidHostnameAllowed(boolean sslInvalidHostnameAllowed) |
When SSL is enabled, controls whether strict hostname checking is disabled.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslKeyStore(String sslKeyStore) |
The location of the key store file for two-way authentication.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslKeyStorePassword(String sslKeyStorePassword) |
The password for the key store file.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslKeyStoreType(String sslKeyStoreType) |
The type of key store file.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslTrustStore(String sslTrustStore) |
The location of the trust store file for the server certificate verification.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslTrustStorePassword(String sslTrustStorePassword) |
The password for the trust store file.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.sslTrustStoreType(String sslTrustStoreType) |
The type of trust store file.
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.startupOptions(StartupOptions startupOptions) |
scan.startup.mode
|
MongoDBSourceBuilder<T> |
MongoDBSourceBuilder.username(String username) |
Name of the database user to be used when connecting to MongoDB.
|