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.
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.