Method testPigStatsAlias

test/org/apache/pig/test/TestPigStats.java:147–172

()

    abstract public void checkPigStatsAlias(PhysicalPlan pp, PigContext pc) throws Exception;

    @Test
    public void testPigStatsAlias() throws Exception {
        try {
            PigServer pig = new PigServer(Util.getLocalTestMode());
            pig.setBatchOn();
            pig.registerQuery("A = load 'input' as (name, age, gpa);");
            pig.registerQuery("B = group A by name;");
            pig.registerQuery("C = foreach B generate group, COUNT(A);");
            pig.registerQuery("D = order C by $1;");
            pig.registerQuery("E = limit D 10;");
            pig.registerQuery("store E into 'alias_output';");

            LogicalPlan lp = getLogicalPlan(pig);
            lp.optimize(pig.getPigContext());
            PhysicalPlan pp = ((HExecutionEngine)pig.getPigContext().getExecutionEngine()).compile(lp,
                    null);
            checkPigStatsAlias(pp, pig.getPigContext());
        } finally {
            File outputfile = new File("alias_output");
            if (outputfile.exists()) {
                // Hadoop Local mode creates a directory
                // Hence we need to delete a directory recursively
                deleteDirectory(outputfile);
            }
        }
    }

    abstract public void checkPigStats(ExecJob job);