public static MongoSplitContext of()

in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitContext.java [81:94]

14 lines of code
1 McCabe index (conditional complexity)


    public static MongoSplitContext of(
            MongoReadOptions readOptions,
            MongoClient mongoClient,
            MongoNamespace namespace,
            BsonDocument collStats) {
        return new MongoSplitContext(
                readOptions,
                mongoClient,
                namespace,
                collStats.getBoolean(SHARDED_FIELD, BsonBoolean.FALSE).getValue(),
                collStats.getNumber(COUNT_FIELD, new BsonInt64(0)).longValue(),
                collStats.getNumber(SIZE_FIELD, new BsonInt64(0)).longValue(),
                collStats.getNumber(AVG_OBJ_SIZE_FIELD, new BsonInt64(0)).longValue());
    }