in spark-job/src/main/java/org/apache/cassandra/diff/PartitionComparator.java [116:134]
private void checkRegularColumnEquality(PartitionStats stats, Row source, Row target) {
for (ColumnMetadata column : tableSpec.getRegularColumns()) {
Object fromSource = source.getObject(column.getName());
Object fromTarget = target.getObject(column.getName());
if (fromSource == null) {
if (fromTarget == null) {
stats.matchedValues++;
} else {
stats.mismatchedValues++;
}
} else {
if (fromSource.equals(fromTarget)) {
stats.matchedValues++;
} else {
stats.mismatchedValues++;
}
}
}
}