void verifyCompactionQueue(Map<String, Long> tables, String dbName, HiveConf conf)
          throws Throwable {
    for(Map.Entry<String, Long> entry : tables.entrySet()) {
      Assert.assertEquals(TestTxnDbUtil.queryToString(conf, "select * from COMPACTION_QUEUE"),
                          entry.getValue().longValue(),
                          TestTxnDbUtil.countQueryAgent(conf,
                    "select count(*) from COMPACTION_QUEUE where cq_database = '" + dbName
                            + "' and cq_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