flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java [101:106]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            return new MongoSourceEnumState(
                    remainingCollections,
                    alreadyProcessedCollections,
                    remainingScanSplits,
                    assignedScanSplits,
                    initialized);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java [125:130]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return new MongoSourceEnumState(
                remainingCollections,
                alreadyProcessedCollections,
                remainingScanSplits,
                assignedScanSplits,
                initialized);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -