Method testLargeFile

test/org/apache/pig/test/TestLargeFile.java:102–120

()

    }

    @Test
    public void testLargeFile () throws Exception {
        System.out.println("Running testLargeFile...");
        pig.registerQuery("A = load " + fileName + ";");
        pig.registerQuery("A = group A by $0;");
        pig.store("A", tmpFile1, "BinStorage()");
        pig.registerQuery("B = foreach A generate group, COUNT($1);");

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

        while (B.hasNext()) {
            Tuple temp = B.next();
            int index = DataType.toInteger(temp.get(0));
            int value = DataType.toInteger(temp.get(1));
            System.out.println("COUNT [" + index + "] = " + COUNT[index] + " B[" + index + "] = " + value);

            assertEquals(COUNT[index].intValue(), value);
        }
    }

    @Test
    public void testOrder() throws Exception {