What was the error? Not an issue, but why do you call the columns dt1, dt2, but not using the name, using the ordinal number insted: $0?
On Fri, Sep 20, 2013 at 6:00 PM, Muni mahesh <[email protected]>wrote: > Hi Hadoopers, > > I did the same thing in Pig 0.8.1 but not Pig 0.11.0 > > register /usr/lib/pig/piggybank.jar; > register /usr/lib/pig/lib/joda-time-2.1.jar; > > DEFINE CustomFormatToISO > org.apache.pig.piggybank.evaluation.datetime.convert.CustomFormatToISO(); > DEFINE ISOToUnix > org.apache.pig.piggybank.evaluation.datetime.convert.ISOToUnix(); > > A = load '/home/user/Desktop/1.tsv' USING PigStorage('\t') AS > (dt1:chararray, dt2:chararray); > B = foreach A generate (long) ISOToUnix(CustomFormatToISO($0, 'yyyy-mm-dd > hh:mm:ss')); > > > *input * > 2013-01-16 04:01:18 2013-01-16 04:01:36 > 2013-01-16 04:02:19 2013-01-16 04:03:11 > > *output* *expected* > (1358308878000,1358308896000) > (1358308939000,1358308991000) >
