private float getRingFraction()

in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java [143:151]

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

    private float getRingFraction(List<TokenRange> tokenRanges) {
        BigInteger addressedTokens = BigInteger.ZERO;
        for (TokenRange tokenRange : tokenRanges) {
            addressedTokens =
                    addressedTokens.add(distance(tokenRange.rangeStart, tokenRange.rangeEnd));
        }
        // it is < 1 because it is a percentage
        return addressedTokens.divide(partitioner.ringSize).floatValue();
    }