0

バッグの構造:

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豚に不慣れです。いくつかの基本を知っています。親切に助けてください。

4

2 に答える 2