@Test
public void sourceContainsExtraRowsAtEnd() {

    TableSpec t = spec("table1", names("c1", "c2"), names("v1", "v2"));
    PartitionComparator comparator = comparator(t,
                                                rows(row(t, 0, 1, 2, 3),
                                                     row(t, 10, 11, 12, 13)),
                                                rows(row(t, 0, 1, 2, 3)));
    PartitionStats stats = comparator.call();
    // The fact that the first row & all its v1 & v2 values match should be reflected in the stats
    assertStats(stats, false, false, 1, 2, 0);
}