Method testDistinct

test/org/apache/pig/test/TestLargeFile.java:144–172

()

    }

    @Test
    public void testDistinct() throws Exception {
        System.out.println("Running testDistinct...");
        pig.registerQuery("A = load " + fileName + ";");
        pig.registerQuery("B = distinct A;");

        Iterator <Tuple> B = pig.openIterator("B");

        Integer[] COUNT_Test = new Integer[max_rand];
        Integer[] COUNT_Data = new Integer[max_rand];

        for(int i = 0; i < max_rand; i++) {
            COUNT_Test[i] = 0;
            if (COUNT[i] > 0) {
                COUNT_Data[i] = 1;
            } else {
                COUNT_Data[i] = 0;
            }
        }

        while(B.hasNext()) {
            int temp = DataType.toInteger(B.next().get(0));
            COUNT_Test[temp] ++;
        }

        for(int i = 0; i < max_rand; i++) {
            assertEquals(COUNT_Test[i].intValue(), COUNT_Data[i].intValue());
        }
    }
}