|
|
-
how to define delimite in hadoop pig stream through
centerqi hu 2013-01-08, 03:26
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]|齐忠
-
Re: how to define delimite in hadoop pig stream through
Cheolsoo Park 2013-01-08, 21:09
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]|齐忠 >
|
|
All projects made searchable here are trademarks of the Apache Software Foundation.
Service operated by
Sematext