You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@pig.apache.org by centerqi hu <ce...@gmail.com> on 2013/01/08 04:26:01 UTC

how to define delimite in hadoop pig stream through

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
-- 
centerqi@gmail.com|齐忠

Re: how to define delimite in hadoop pig stream through

Posted by Cheolsoo Park <ch...@cloudera.com>.

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 <ce...@gmail.com> 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
> --
> centerqi@gmail.com|齐忠
>