private void testSdpoBucketed(boolean isVectorized, int bucketingVersion)
      throws Exception {
    hiveConf.setBoolVar(HiveConf.ConfVars.HIVE_VECTORIZATION_ENABLED, isVectorized);
    runStatementOnDriver("drop table if exists acid_uap");
    runStatementOnDriver("create transactional table acid_uap(a int, b varchar(128)) " +
        "partitioned by (ds string) clustered by (a) into 2 buckets stored as orc TBLPROPERTIES " +
        "('bucketing_version'='" + bucketingVersion + "')");
    runStatementOnDriver("insert into table acid_uap partition (ds='tomorrow') " +
        "values (1, 'bah'),(2, 'yah')");
    runStatementOnDriver("insert into table acid_uap partition (ds='today') " +
        "values (1, 'bah'),(2, 'yah')");
    runStatementOnDriver("select a,b, ds from acid_uap order by a,b, ds");

    String testQuery = "select ROW__ID, a, b, ds, INPUT__FILE__NAME from acid_uap order by ds, a, b";
    String[][] expected = new String[][]{
        {"{\"writeid\":2,\"bucketid\":536936448,\"rowid\":0}\t1\tbah\ttoday",
            "warehouse/acid_uap/ds=today/delta_0000002_0000002_0000/bucket_00001_0"},
        {"{\"writeid\":2,\"bucketid\":536870912,\"rowid\":0}\t2\tyah\ttoday",
            "warehouse/acid_uap/ds=today/delta_0000002_0000002_0000/bucket_00000_0"},

        {"{\"writeid\":1,\"bucketid\":536936448,\"rowid\":0}\t1\tbah\ttomorrow",
            "warehouse/acid_uap/ds=tomorrow/delta_0000001_0000001_0000/bucket_00001_0"},
        {"{\"writeid\":1,\"bucketid\":536870912,\"rowid\":0}\t2\tyah\ttomorrow",
            "warehouse/acid_uap/ds=tomorrow/delta_0000001_0000001_0000/bucket_00000_0"}};
    checkResultAndVectorization(expected, testQuery, "after insert", LOG);

    runStatementOnDriver("update acid_uap set b = 'fred'");

    String[][] expected2 = new String[][]{
        {"{\"writeid\":3,\"bucketid\":536936449,\"rowid\":0}\t1\tfred\ttoday",
            "warehouse/acid_uap/ds=today/delta_0000003_0000003_0001/bucket_00001_0"},
        {"{\"writeid\":3,\"bucketid\":536870913,\"rowid\":0}\t2\tfred\ttoday",
            "warehouse/acid_uap/ds=today/delta_0000003_0000003_0001/bucket_00000_0"},

        {"{\"writeid\":3,\"bucketid\":536936449,\"rowid\":0}\t1\tfred\ttomorrow",
            "warehouse/acid_uap/ds=tomorrow/delta_0000003_0000003_0001/bucket_00001_0"},
        {"{\"writeid\":3,\"bucketid\":536870913,\"rowid\":0}\t2\tfred\ttomorrow",
            "warehouse/acid_uap/ds=tomorrow/delta_0000003_0000003_0001/bucket_00000_0"}};
    checkResultAndVectorization(expected2, testQuery, "after update", LOG);
  }
Test that rows are routed to proper files based on bucket col/ROW__ID
Only the Vectorized Acid Reader checks if bucketId in ROW__ID inside the file
matches the file name and only for files in delete_delta
ql/src/test/org/apache/hadoop/hive/ql/TestTxnCommands3.java