in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java [126:141]
public DynamicTableSource createDynamicTableSource(Context context) {
final FactoryUtil.TableFactoryHelper helper =
FactoryUtil.createTableFactoryHelper(this, context);
ReadableConfig options = helper.getOptions();
MongoConfiguration config = new MongoConfiguration(options);
helper.validate();
return new MongoDynamicTableSource(
getConnectionOptions(config),
getReadOptions(config),
getLookupCache(options),
config.getLookupMaxRetries(),
config.getLookupRetryIntervalMs(),
context.getPhysicalRowDataType());
}