flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/MongoDBSource.java
public Builder<T> copyExistingMaxThreads(int copyExistingMaxThreads) {
            checkArgument(copyExistingMaxThreads > 0);
            this.copyExistingMaxThreads = copyExistingMaxThreads;
            return this;
        }
/**
         * copy.existing.max.threads
         *
         * <p>The number of threads to use when performing the data copy. Defaults to the number of
         * processors. Default: defaults to the number of processors
         */
copy.existing.max.threads
The number of threads to use when performing the data copy. Defaults to the number of
processors. Default: defaults to the number of processors
copy . existing . max . threads The number of threads to use when performing the data copy . Defaults to the number of processors . Default : defaults to the number of processors
public Builder<T> copyExistingMaxThreads(int copyExistingMaxThreads) {
            checkArgument(copyExistingMaxThreads > 0);
            this.copyExistingMaxThreads = copyExistingMaxThreads;
            return this;
        }
public Builder < T > copyExistingMaxThreads ( int copyExistingMaxThreads ) { checkArgument ( copyExistingMaxThreads > 0 ) ; this . copyExistingMaxThreads = copyExistingMaxThreads ; return this ; }
copy.existing.max.threads
 <p>The number of threads to use when performing the data copy.
copy . existing . max . threads <p > The number of threads to use when performing the data copy .