Method testMergeJoin

test/org/apache/pig/test/TestEmptyInputDir.java:128–156

()

    }

    @Test
    public void testMergeJoin() throws Exception {
        PrintWriter w = new PrintWriter(new FileWriter(PIG_FILE));
        w.println("A = load '" + INPUT_FILE + "';");
        w.println("B = load '" + EMPTY_DIR + "';");
        w.println("C = join A by $0, B by $0 using 'merge';");
        w.println("store C into '" + OUTPUT_FILE + "';");
        w.close();

        try {
            String[] args = { "-x", cluster.getExecType().name(), PIG_FILE, };
            PigStats stats = PigRunner.run(args, null);

            assertTrue(stats.isSuccessful());

            // This assert fails on 205 due to MAPREDUCE-3606
            if (Util.isMapredExecType(cluster.getExecType())
                    && !Util.isHadoop205() && !Util.isHadoop1_x()) {
                // the indexer job has zero maps
                MRJobStats js = (MRJobStats) stats.getJobGraph().getSources().get(0);
                assertEquals(0, js.getNumberMaps());
            }

            assertEmptyOutputFile();
        } finally {
            new File(PIG_FILE).delete();
            Util.deleteFile(cluster, OUTPUT_FILE);
        }
    }

    @Test
    public void testFRJoin() throws Exception {