Method testJoinTupleFieldKey

test/org/apache/pig/test/TestJoinBase.java:361–390

()

    @Test
    public void testJoinTupleFieldKey() throws Exception{
        String[] input1 = {
                "(1,a)",
                "(2,aa)"
        };
        String[] input2 = {
                "(1,b)",
                "(2,bb)"
        };

        String firstInput = createInputFile("a.txt", input1);
        String secondInput = createInputFile("b.txt", input2);

        String script = "a = load '"+ Util.encodeEscape(firstInput) +"' as (a:tuple(a1:int, a2:chararray));" +
                "b = load '"+ Util.encodeEscape(secondInput) +"' as (b:tuple(b1:int, b2:chararray));" +
                "c = join a by a.a1, b by b.b1;";
        Util.registerMultiLineQuery(pigServer, script);
        Iterator<Tuple> it = pigServer.openIterator("c");

        List<Tuple> expectedResults = Util.getTuplesFromConstantTupleStrings(
                new String[] {
                        "((1,'a'),(1,'b'))",
                        "((2,'aa'),(2,'bb'))"
                        });
        Util.checkQueryOutputsAfterSort(it, expectedResults);

        deleteInputFile(firstInput);
        deleteInputFile(secondInput);
    }

    @Test
    public void testJoinNullTupleFieldKey() throws Exception{