バッグの構造:
emp = LOAD '...../emp.csv' using PigStorage(',') AS
(ename:chararray,id:int,job:chararray,sal:double)
このバッグには従業員の詳細が含まれています。ジョブに基づいてデータを分割したい。
Bag = split emp into mngr if job == 'MANAGER';
これは機能していませんError 1200.
それにもう1つの条件を含めるとfor ex.- sal10k if sal<10000、それは機能しています。しかし、なぜ1つだけではないのchararrayですか?
私はhadoop豚に不慣れです。いくつかの基本を知っています。親切に助けてください。