Piggybank ISOToUnix

ISOToUnix

register /home/hadoop/.versions/pig-0.11.1.1/lib/pig/piggybank-0.11.1.1-amzn.jar;
define ISOToUnix org.apache.pig.piggybank.evaluation.datetime.convert.ISOToUnix();

data = load 'data_file.txt' using PigStorage('\t') as (user_id:int, datetime:chararray);

data = limit data 10000;

pdata = foreach generate
  user_id,
  ISOToUnix(datetime) / 1000 as timestamp:long;

dump pdata;