protected MongoSourceSplitState initializedState()

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

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

    protected MongoSourceSplitState initializedState(MongoSourceSplit split) {
        if (split instanceof MongoScanSourceSplit) {
            return new MongoScanSourceSplitState((MongoScanSourceSplit) split);
        } else {
            throw new IllegalArgumentException("Unknown split type.");
        }
    }