Method testBloomJoin

test/org/apache/pig/test/TestEmptyInputDir.java:252–276

()

    }

    @Test
    public void testBloomJoin() throws Exception {
        PrintWriter w = new PrintWriter(new FileWriter(PIG_FILE));
        w.println("A = load '" + INPUT_FILE + "' as (x:int);");
        w.println("B = load '" + EMPTY_DIR + "' as (x:int);");
        w.println("C = join B by $0, A by $0 using 'bloom';");
        w.println("D = join A by $0, B by $0 using 'bloom';");
        w.println("store C into '" + OUTPUT_FILE + "';");
        w.println("store D into 'output1';");
        w.close();

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

            assertTrue(stats.isSuccessful());
            assertEquals(0, stats.getNumberRecords(OUTPUT_FILE));
            assertEquals(0, stats.getNumberRecords("output1"));
            assertEmptyOutputFile();
        } finally {
            new File(PIG_FILE).delete();
            Util.deleteFile(cluster, OUTPUT_FILE);
            Util.deleteFile(cluster, "output1");
        }
    }

    @Test
    public void testBloomJoinOuter() throws Exception {