|
|
-
jython udfsStan Rosenberg 2011-10-12, 23:29
Hi,
I have three constant udfs in jython: @outputSchema("m:map[bag{tuple()}]") def dummy1(): return {"key":[("value1", "value2")]} @outputSchema("m:map[tuple()]") def dummy2(): return {"key":("value1", "value2")} # doesn't work! @outputSchema("m:map[bag{}]") def dummy3(): return {"key":["value1", "value2"]} The first two are fine. The last one which returns a map whose values are lists does not work. (I am getting ClassCastException: java.lang.String cannot be cast to org.apache.pig.data.Tuple). Could somebody explain why? Thanks, stan |