flatten is not implemented as a UDF. It's implemented as part of the foreach code, which is in src/org/apache/pig/backend/hadoop/ executionengine/physicalLayer/relationalOperators/POForEach.java

Alan.

On May 22, 2010, at 3:48 AM, Alexander Schätzle wrote:

Hi,

does anybody know where to find the source code of the flatten() function of Pig?
I can't find it in the package "org.apache.pig.builtin" of pig.jar.

Thx in advance,
Alex



Reply via email to