Method storeAndCopyLocally

test/org/apache/pig/test/TestStore.java:112–125

(DataBag inpDB)

    }

    private void storeAndCopyLocally(DataBag inpDB) throws Exception {
        setUpInputFileOnCluster(inpDB);
        String script = "a = load '" + inputFileName + "'; " +
                "store a into '" + outputFileName + "' using PigStorage('\t');" +
                "fs -ls " + TESTDIR;
        ps.setBatchOn();
        Util.registerMultiLineQuery(ps, script);
        ps.executeBatch();
        Path path = getFirstOutputFile(cluster.getConfiguration(),
                new Path(outputFileName), cluster.getExecType(), true);
        Util.copyFromClusterToLocal(
                cluster,
                path.toString(), outputFileName);
    }

    @AfterClass
    public static void oneTimeTearDown() throws Exception {