Method testSchemaWithSplit

test/org/apache/pig/test/TestPigSplit.java:109–144

()

    }

    @Test
    public void testSchemaWithSplit() throws Exception {
        inputFileName = "testSchemaWithSplit-input.txt";
        String[] input = { "2", "12", "42" };
        for (ExecType execType : execTypes) {
            try {
                setUp(execType);
                createInput(input, execType);
                pigServer.registerQuery("a = load '" + inputFileName
                        + "' as (value:chararray);");
                pigServer
                        .registerQuery("split a into b if value < '20', c if value > '10';");
                pigServer.registerQuery("b1 = order b by value;");
                pigServer.registerQuery("c1 = order c by value;");

                // order in lexicographic, so 12 comes before 2
                Iterator<Tuple> iter = pigServer.openIterator("b1");
                assertTrue("b1 has an element", iter.hasNext());
                assertEquals("first item in b1", "12", iter.next().get(0));
                assertTrue("b1 has an element", iter.hasNext());
                assertEquals("second item in b1", "2", iter.next().get(0));
                assertFalse("b1 is over", iter.hasNext());

                iter = pigServer.openIterator("c1");
                assertTrue("c1 has an element", iter.hasNext());
                assertEquals("first item in c1", "12", iter.next().get(0));
                assertTrue("c1 has an element", iter.hasNext());
                assertEquals("second item in c1", "2", iter.next().get(0));
                assertTrue("c1 has an element", iter.hasNext());
                assertEquals("third item in c1", "42", iter.next().get(0));
                assertFalse("c1 is over", iter.hasNext());
            } finally {
                tearDown(execType);
            }
        }
    }

    @Test
    public void testLongEvalSpec() throws Exception {