public static void appendMerge(WarehouseInstance primary, String primaryDbName, String primaryDbNameExtra,
                           List<String> selectStmtList, List<String[]> expectedValues) throws Throwable {
    String tableName = "testMerge";
    String tableNameMerge = tableName + "_Merge";

    insertForMerge(primary, primaryDbName, tableName, tableNameMerge, false);
    selectStmtList.add("select last_update_user from " + tableName + " order by last_update_user");
    expectedValues.add(new String[] {"creation", "creation", "creation", "creation", "creation",
            "creation", "creation", "merge_update", "merge_insert", "merge_insert"});
    selectStmtList.add("select ID from " + tableNameMerge + " order by ID");
    expectedValues.add(new String[] {"1", "4", "7", "8", "8", "11"});
  }
ReplicationTestUtils - static helper functions for replication test
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/ReplicationTestUtils.java