pelick / flare-spork Goto Github PK

UDF output is not proper, it is operating on the first column even if you specify some other column

Eg:
REGISTER /home/akhld/mobi/temp/pig/demo/tutorial.jar;
A = load 'hdfs://localhost:9000/input/' USING PigStorage('\t') AS (user:chararray, time:int, query:chararray);
B = FOREACH A GENERATE org.apache.pig.tutorial.ToLower(query) as query;
STORE B INTO '/tmp/query';

Fails to Operate on "query" column, but the processing happens on "user" column.