private void drain()

in spark-job/src/main/java/org/apache/cassandra/diff/RangeComparator.java [189:199]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    private void drain(Iterator<PartitionKey> sourceKeys,
                             Iterator<PartitionKey> targetKeys,
                             RangeStats rangeStats) {
        if (sourceKeys.hasNext()) {
            logger.info("Source keys not exhausted {}", context);
            sourceKeys.forEachRemaining(key -> onlyInSource(rangeStats, key));
        } else if (targetKeys.hasNext()) {
            logger.info("Target keys not exhausted: {}", context);
            targetKeys.forEachRemaining(key -> onlyInTarget(rangeStats, key));
        }
    }