in spark-job/src/main/java/org/apache/cassandra/diff/PartitionComparator.java [102:114]
private boolean clusteringsEqual(Row source, Row target) {
for (ColumnMetadata column : tableSpec.getClusteringColumns()) {
Object fromSource = source.getObject(column.getName());
Object fromTarget = target.getObject(column.getName());
if ((fromSource == null) != (fromTarget == null))
return false;
if (fromSource != null && !fromSource.equals(fromTarget))
return false;
}
return true;
}