in spark-job/src/main/java/org/apache/cassandra/diff/RangeStats.java [66:95]
private RangeStats(long matchedPartitions,
long mismatchedPartitions,
long errorPartitions,
long skippedPartitions,
long onlyInSource,
long onlyInTarget,
long matchedRows,
long matchedValues,
long mismatchedValues) {
this.matchedPartitions = new LongAdder();
this.mismatchedPartitions = new LongAdder();
this.errorPartitions = new LongAdder();
this.skippedPartitions = new LongAdder();
this.onlyInSource = new LongAdder();
this.onlyInTarget = new LongAdder();
this.matchedRows = new LongAdder();
this.matchedValues = new LongAdder();
this.mismatchedValues = new LongAdder();
this.matchedPartitions.add(matchedPartitions);
this.mismatchedPartitions.add(mismatchedPartitions);
this.errorPartitions.add(errorPartitions);
this.skippedPartitions.add(skippedPartitions);
this.onlyInSource.add(onlyInSource);
this.onlyInTarget.add(onlyInTarget);
this.matchedRows.add(matchedRows);
this.matchedValues.add(matchedValues);
this.mismatchedValues.add(mismatchedValues);
}