Package org.apache.flink.cdc.connectors.mongodb.source.connection

Class MongoClientPool

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.source.connection.MongoClientPool

public class MongoClientPool
extends Object

A MongoDB Client pools.

Method Summary

Modifier and Type	Method	Description
static MongoClientPool	getInstance()
com.mongodb.client.MongoClient	getOrCreateMongoClient(MongoDBSourceConfig sourceConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static MongoClientPool getInstance()

getOrCreateMongoClient

public com.mongodb.client.MongoClient getOrCreateMongoClient(MongoDBSourceConfig sourceConfig)