Method testDefaultJoin

test/org/apache/pig/test/TestJoinBase.java:61–99

()

    }

    @Test
    public void testDefaultJoin() throws Exception {
        String[] input1 = {
                "hello\t1",
                "bye\t2",
                "\t3"
        };
        String[] input2 = {
                "hello\tworld",
                "good\tmorning",
                "\tevening"
        };

        String firstInput = createInputFile("a.txt", input1);
        String secondInput = createInputFile("b.txt", input2);
        Tuple expectedResult = (Tuple)Util.getPigConstant("('hello',1,'hello','world')");

        // with schema
        String script = "a = load '"+ Util.encodeEscape(firstInput) +"' as (n:chararray, a:int); " +
                "b = load '"+ Util.encodeEscape(secondInput) +"' as (n:chararray, m:chararray); " +
                "c = join a by $0, b by $0;";
        Util.registerMultiLineQuery(pigServer, script);
        Iterator<Tuple> it = pigServer.openIterator("c");
        assertTrue(it.hasNext());
        assertEquals(expectedResult, it.next());
        assertFalse(it.hasNext());

        // without schema
        script = "a = load '"+ Util.encodeEscape(firstInput) + "'; " +
        "b = load '" + Util.encodeEscape(secondInput) + "'; " +
        "c = join a by $0, b by $0;";
        Util.registerMultiLineQuery(pigServer, script);
        it = pigServer.openIterator("c");
        assertTrue(it.hasNext());
        assertEquals(expectedResult.toString(), it.next().toString());
        assertFalse(it.hasNext());
        deleteInputFile(firstInput);
        deleteInputFile(secondInput);
    }


    @Test