Method testUDFReturnMap_MapReduceMode

test/org/apache/pig/test/TestUDF.java:91–108

()

    }

    @Test
    public void testUDFReturnMap_MapReduceMode() throws Exception {
        Util.createInputFile(cluster, "a.txt", new String[] { "dummy",
                "dummy" });
        FileLocalizer.deleteTempFiles();
        PigServer pig = new PigServer(cluster.getExecType(), cluster
                .getProperties());
        pig.registerQuery("A = LOAD 'a.txt';");
        pig.registerQuery("B = FOREACH A GENERATE org.apache.pig.test.utils.MyUDFReturnMap();");

        Iterator<Tuple> iterator = pig.openIterator("B");
        while (iterator.hasNext()) {
            Tuple tuple = iterator.next();
            @SuppressWarnings("unchecked")
            Map<Object, Object> result = (Map<Object, Object>) tuple.get(0);
            assertEquals(result, MyUDFReturnMap.map);
        }
    }

    @Test
    public void testUDFMultiLevelOutputSchema() throws Exception {