private void checkRegularColumnEquality()

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++;
                }
            }
        }
    }