public MongoScanSourceSplit deserializeMongoScanSourceSplit()

in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java [87:103]

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

    public MongoScanSourceSplit deserializeMongoScanSourceSplit(int version, DataInputStream in)
            throws IOException {
        switch (version) {
            case 0:
                String splitId = in.readUTF();
                String database = in.readUTF();
                String collection = in.readUTF();
                BsonDocument min = BsonDocument.parse(in.readUTF());
                BsonDocument max = BsonDocument.parse(in.readUTF());
                BsonDocument hint = BsonDocument.parse(in.readUTF());
                int offset = in.readInt();
                return new MongoScanSourceSplit(
                        splitId, database, collection, min, max, hint, offset);
            default:
                throw new IOException("Unknown version: " + version);
        }
    }