Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Pig >> mail # user >> ISOToUNix working in Pig 0.8.1 but not in Pig 0.11.0


Copy link to this message
-
Re: ISOToUNix working in Pig 0.8.1 but not in Pig 0.11.0
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)
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB