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)