public void addSplitsBack()

in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java [112:121]

• 8 lines of code
• 3 McCabe index (conditional complexity)

    public void addSplitsBack(Collection<MongoSourceSplit> splits) {
        for (MongoSourceSplit split : splits) {
            if (split instanceof MongoScanSourceSplit) {
                remainingScanSplits.add((MongoScanSourceSplit) split);
                // we should remove the add-backed splits from the assigned list,
                // because they are failed
                assignedScanSplits.remove(split.splitId());
            }
        }
    }