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 >> how to define delimite in hadoop pig stream through


Copy link to this message
-
Re: how to define delimite in hadoop pig stream through
Hi,

>> java.lang.ClassCastException: org.apache.pig.builtin.PigStorage cannot
be cast to org.apache.pig.PigToStream

Please try PigStreaming(',') instead of PigStorage(',').

Thanks,
Cheolsoo
On Mon, Jan 7, 2013 at 7:26 PM, centerqi hu <[EMAIL PROTECTED]> wrote:

> hi all
> how to define delimite in hadoop pig  stream through?
>
>
> Code is as follows
> define X `actionList.py`ship('/proxy/macid2uid/actionList.py')  us
> ing PigStorage(',');
> schemeData = stream rawLog through  X  as (platForm, mac,uid);
>
> The Exception
> java.lang.ClassCastException: org.apache.pig.builtin.PigStorage cannot be
> cast to org.apache.pig.PigToStream
>
> thx
> --
> [EMAIL PROTECTED]|齐忠
>
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