Member since
06-20-2017
2
Posts
0
Kudos Received
0
Solutions
06-21-2017
04:52 AM
I am adding pig log4j.properties from ambari gui .Thanks
... View more
06-20-2017
04:44 PM
public class TestUdf extends EvalFunc<String>{
@Override
public String exec(Tuple input) throws IOException {
log.info("My message*********************"); String inputData = (String)input.get(0); return inputData;
} } Please check my pig log Properties file in screenshot which is being used by my pig script as shown below. REGISTER hdfs:///user/maria_dev/test.jar;
aa = LOAD 'mydoc' USING PigStorage('\t') as (email: chararray) ;
finaloutput =FOREACH aa GENERATE test.TestUdf(email) as email;
dump finaloutput;
... View more
Labels:
- Labels:
-
Apache Pig