Method testParseInputScript

test/org/apache/pig/TestMain.java:158–185

()

    @Test
    public void testParseInputScript() throws Exception {
        File input = Util.createInputFile("tmp", "",
                new String[]{"{(1,1.0)}\ttestinputstring1",
                        "{(2,2.0)}\ttestinputstring1",
                        "{(3,3.0)}\ttestinputstring1",
                        "{(4,4.0)}\ttestinputstring1"}
        );
        File out = new File(System.getProperty("java.io.tmpdir")+"/testParseInputScriptOut");
        File scriptFile = Util.createInputFile("pigScript", "",
                new String[]{"A = load '"+input.getAbsolutePath()+"' as (a:{(x:chararray, y:float)}, b:chararray);",
                        "B = foreach A generate\n" +
                                "    b,\n" +
                                "    (bag{tuple(long)}) a.x as ax:{(x:long)};",
                        "store B into '"+out.getAbsolutePath()+"';"}
        );

        Main.run(new String[]{"-x", "local", scriptFile.getAbsolutePath()}, null);
        BufferedReader file = new BufferedReader(new FileReader(new File(out.getAbsolutePath()+"/part-m-00000")));
        String line;
        int count = 0;
        while(( line = file.readLine()) != null) {
            count++;
        }
        assertEquals(4,count);
        Util.deleteDirectory(new File(out.getAbsolutePath()));
        assertTrue(!new File(out.getAbsolutePath()).exists());
    }

    public static class TestNotificationListener2 extends TestNotificationListener {
        protected boolean hadArgs = false;