java.lang.Object
- org.apache.flink.cdc.connectors.mongodb.source.config.MongoDBSourceConfig

All Implemented Interfaces:

Serializable, SourceConfig
```
public class MongoDBSourceConfig
extends Object
implements SourceConfig
```
A MongoDB Source configuration which is used by MongoDBSource.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.cdc.connectors.base.config.SourceConfig
  SourceConfig.Factory<C extends SourceConfig>

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`disableCursorTimeout()`
`boolean`	`equals(Object o)`
`int`	`getBatchSize()`
`List<String>`	`getCollectionList()`
`String`	`getConnectionString()`
`List<String>`	`getDatabaseList()`
`int`	`getHeartbeatIntervalMillis()`
`String`	`getHosts()`
`String`	`getPassword()`
`int`	`getPollAwaitTimeMillis()`
`int`	`getPollMaxBatchSize()`
`int`	`getSamplesPerChunk()`
`String`	`getScheme()`
`int`	`getSplitMetaGroupSize()`
`int`	`getSplitSize()`
`String`	`getSslKeyStore()`
`String`	`getSslKeyStorePassword()`
`String`	`getSslKeyStoreType()`
`String`	`getSslTrustStore()`
`String`	`getSslTrustStorePassword()`
`String`	`getSslTrustStoreType()`
`StartupOptions`	`getStartupOptions()`
`String`	`getUsername()`
`int`	`hashCode()`
`boolean`	`isAssignUnboundedChunkFirst()`
`boolean`	`isCloseIdleReaders()`
`boolean`	`isFullDocPrePostImageEnabled()`
`boolean`	`isIncludeSchemaChanges()`
`boolean`	`isReleaseSnapshotMetadataEnabled()`	Whether releasing the snapshot split metadata held by the source coordinator once the stream split is assembled and checkpoint-covered is enabled.
`boolean`	`isScanNewlyAddedTableEnabled()`
`boolean`	`isSkipSnapshotBackfill()`
`boolean`	`isSslEnabled()`
`boolean`	`isSslInvalidHostnameAllowed()`
`boolean`	`isUpdateLookup()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - getScheme
```
public String getScheme()
```
  - getHosts
```
public String getHosts()
```
  - getConnectionString
```
public String getConnectionString()
```
  - getUsername
```
@Nullable
public String getUsername()
```
  - getPassword
```
@Nullable
public String getPassword()
```
  - getDatabaseList
```
@Nullable
public List<String> getDatabaseList()
```
  - getCollectionList
```
@Nullable
public List<String> getCollectionList()
```
  - getBatchSize
```
public int getBatchSize()
```
  - getPollAwaitTimeMillis
```
public int getPollAwaitTimeMillis()
```
  - getPollMaxBatchSize
```
public int getPollMaxBatchSize()
```
  - getHeartbeatIntervalMillis
```
public int getHeartbeatIntervalMillis()
```
  - isUpdateLookup
```
public boolean isUpdateLookup()
```
  - getStartupOptions
```
public StartupOptions getStartupOptions()
```
    Specified by:
    
    getStartupOptions in interface SourceConfig
  - getSplitSize
```
public int getSplitSize()
```
    Specified by:
    
    getSplitSize in interface SourceConfig
  - getSplitMetaGroupSize
```
public int getSplitMetaGroupSize()
```
    Specified by:
    
    getSplitMetaGroupSize in interface SourceConfig
  - getSamplesPerChunk
```
public int getSamplesPerChunk()
```
  - isIncludeSchemaChanges
```
public boolean isIncludeSchemaChanges()
```
    Specified by:
    
    isIncludeSchemaChanges in interface SourceConfig
  - isCloseIdleReaders
```
public boolean isCloseIdleReaders()
```
    Specified by:
    
    isCloseIdleReaders in interface SourceConfig
  - isFullDocPrePostImageEnabled
```
public boolean isFullDocPrePostImageEnabled()
```
  - disableCursorTimeout
```
public boolean disableCursorTimeout()
```
  - isSkipSnapshotBackfill
```
public boolean isSkipSnapshotBackfill()
```
    Specified by:
    
    isSkipSnapshotBackfill in interface SourceConfig
  - isScanNewlyAddedTableEnabled
```
public boolean isScanNewlyAddedTableEnabled()
```
    Specified by:
    
    isScanNewlyAddedTableEnabled in interface SourceConfig
  - isAssignUnboundedChunkFirst
```
public boolean isAssignUnboundedChunkFirst()
```
    Specified by:
    
    isAssignUnboundedChunkFirst in interface SourceConfig
  - isSslEnabled
```
public boolean isSslEnabled()
```
  - isSslInvalidHostnameAllowed
```
public boolean isSslInvalidHostnameAllowed()
```
  - getSslKeyStore
```
@Nullable
public String getSslKeyStore()
```
  - getSslKeyStorePassword
```
@Nullable
public String getSslKeyStorePassword()
```
  - getSslKeyStoreType
```
public String getSslKeyStoreType()
```
  - getSslTrustStore
```
@Nullable
public String getSslTrustStore()
```
  - getSslTrustStorePassword
```
@Nullable
public String getSslTrustStorePassword()
```
  - getSslTrustStoreType
```
public String getSslTrustStoreType()
```
  - isReleaseSnapshotMetadataEnabled
```
public boolean isReleaseSnapshotMetadataEnabled()
```
    Description copied from interface: SourceConfig
    
    Whether releasing the snapshot split metadata held by the source coordinator once the stream split is assembled and checkpoint-covered is enabled. Default false so existing jobs and configs that do not set the option are unaffected.
    
    Specified by:
    
    isReleaseSnapshotMetadataEnabled in interface SourceConfig
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object

Class MongoDBSourceConfig

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.cdc.connectors.base.config.SourceConfig

Method Summary

Methods inherited from class java.lang.Object

Method Detail

getScheme

getHosts

getConnectionString

getUsername

getPassword

getDatabaseList

getCollectionList

getBatchSize

getPollAwaitTimeMillis

getPollMaxBatchSize

getHeartbeatIntervalMillis

isUpdateLookup

getStartupOptions

getSplitSize

getSplitMetaGroupSize

getSamplesPerChunk

isIncludeSchemaChanges

isCloseIdleReaders

isFullDocPrePostImageEnabled

disableCursorTimeout

isSkipSnapshotBackfill

isScanNewlyAddedTableEnabled

isAssignUnboundedChunkFirst

isSslEnabled

isSslInvalidHostnameAllowed

getSslKeyStore

getSslKeyStorePassword

getSslKeyStoreType

getSslTrustStore

getSslTrustStorePassword

getSslTrustStoreType

isReleaseSnapshotMetadataEnabled

equals

hashCode