in src/main/java/org/apache/accumulo/testing/merkle/cli/CompareTables.java [138:166]
public static void main(String[] args) throws Exception {
CompareTablesOpts opts = new CompareTablesOpts();
opts.parseArgs("CompareTables", args);
if (opts.isIteratorPushdown() && null != opts.getSplitsFile()) {
throw new IllegalArgumentException(
"Cannot use iterator pushdown with anything other than table split points");
}
CompareTables compareTables = new CompareTables(opts);
Map<String,String> tableToHashes = compareTables.computeAllHashes();
boolean hashesEqual = true;
String previousHash = null;
for (Entry<String,String> entry : tableToHashes.entrySet()) {
// Set the previous hash if we dont' have one
if (null == previousHash) {
previousHash = entry.getValue();
} else if (hashesEqual) {
// If the hashes are still equal, check that the new hash is
// also equal
hashesEqual = previousHash.equals(entry.getValue());
}
System.out.println(entry.getKey() + " " + entry.getValue());
}
System.exit(hashesEqual ? 0 : 1);
}