void verifyWriteIdsForTables(Map<String, Long> tables, HiveConf conf, String dbName)
          throws Throwable {
    for(Map.Entry<String, Long> entry : tables.entrySet()) {
      Assert.assertEquals(TestTxnDbUtil.queryToString(conf, "select * from TXN_TO_WRITE_ID"),
                          entry.getValue().longValue(),
                          TestTxnDbUtil.countQueryAgent(conf,
          "select count(*) from TXN_TO_WRITE_ID where t2w_database = '"
                    + dbName.toLowerCase()
                    + "' and t2w_table = '" + entry.getKey() + "'"));
    }
  }
TestReplicationScenariosAcidTablesBase - base class for replication for ACID tables tests
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/BaseReplicationScenariosAcidTables.java