protected void onSplitFinished()

in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java [72:78]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    protected void onSplitFinished(Map<String, MongoSourceSplitState> finishedSplitIds) {
        for (MongoSourceSplitState splitState : finishedSplitIds.values()) {
            MongoSourceSplit sourceSplit = splitState.toMongoSourceSplit();
            LOG.info("Split {} is finished.", sourceSplit.splitId());
        }
        context.sendSplitRequest();
    }