private BigInteger distance()

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

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

    private BigInteger distance(BigInteger token1, BigInteger token2) {
        // token2 > token1
        if (token2.compareTo(token1) > 0) {
            return token2.subtract(token1);
        } else {
            return token2.subtract(token1).add(partitioner.ringSize);
        }
    }