Method testFullOuterJoin

test/org/apache/pig/test/TestJoinBase.java:292–358

()

    }

    @Test
    public void testFullOuterJoin() 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);
        List<Tuple> expectedResults = Util.getTuplesFromConstantTupleStrings(
                new String[] {
                        "(null,null,null,'evening')" ,
                        "(null,null,'good','morning')" ,
                        "('hello',1,'hello','world')" ,
                        "('bye',2,null,null)" ,
                        "(null,3,null,null)"
                                       });
        // with and without optional outer
        for(int i = 0; i < 2; i++) {
            // with schema
            String script = "a = load '"+ Util.encodeEscape(firstInput) +"' as (n:chararray, a:int); " +
                    "b = load '"+ Util.encodeEscape(secondInput) +"' as (n:chararray, m:chararray); ";
            if(i == 0) {
                script +=  "c = join a by $0 full outer, b by $0;" ;
            } else {
                script +=  "c = join a by $0 full, b by $0;" ;
            }
            script += "d = order c by $1, $3;";
            // ensure we parse correctly
            Util.buildLp(pigServer, script);

            // run query and test results only once
            if(i == 0) {
                Util.registerMultiLineQuery(pigServer, script);
                Iterator<Tuple> it = pigServer.openIterator("d");
                int counter= 0;
                while(it.hasNext()) {
                    assertEquals(expectedResults.get(counter++), it.next());
                }
                assertEquals(expectedResults.size(), counter);

                // without schema
                script = "a = load '"+ Util.encodeEscape(firstInput) +"'; " +
                "b = load '"+ Util.encodeEscape(secondInput) +"'; " ;
                if(i == 0) {
                    script +=  "c = join a by $0 full outer, b by $0;" ;
                } else {
                    script +=  "c = join a by $0 full, b by $0;" ;
                }
                try {
                    Util.registerMultiLineQuery(pigServer, script);