public int getNoOfEventsDumped(String dumpLocation, HiveConf conf) throws Throwable {
    IncrementalLoadEventsIterator itr = new IncrementalLoadEventsIterator(
            dumpLocation + File.separator + ReplUtils.REPL_HIVE_BASE_DIR, conf);
    return itr.getTotalEventsCount();
  }
verify's result without regard for ordering.
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/WarehouseInstance.java