ブタスクリプトによる平均計算

Question

/*calculating average for itemssold(int) grouped by city */ 

a = LOAD 'sales.txt' USING PigStorage(','); /*loading sales data and it has 50 fields that are comma separated*/ 
b = FOREACH a GENERATE $3 as city:chararray, $4 as itemssold:int;/*defining schema for needed fields*/ 
c = GROUP b BY city; /*grouping by city*/ 
d = FOREACH c GENERATE group,AVG(b.itemssold); /*calculating average*/ 
dump d; /*writing output*/ 

ここで私は都市別に分類されたitemssoldの平均を計算しようとしています。

Error: Error while computing Average.

誰でもこのエラーを修正できますか？

注：sales.txtには50個のフィールドがカンマで区切られているので、Sales.txtを関係自体にロードする際に、すべてのフィールドにスキーマを定義したくありません。

Answer 1

たぶん、あなたのデータは、いくつかの欠損値が含まれ、このように最初にそれをフィルタリングしてみてください：上記のコードは働い

no_nulls = FILTER b BY itemssold is not null; 

Answer 2

a = LOAD 'sales.txt' USING PigStorage(','); 
b = FOREACH a GENERATE (chararray) $3 as city, (int) $4 as itemssold; 
c = GROUP b BY city; 
d = FOREACH c GENERATE group,AVG(b.itemssold); 
dump d; 

。関係b GENERATEでは、私は鋳造ではなくスキーマを定義しようとしていたので、豚は混乱しました。修正しました今&それは働いた。あなたの提案に感謝します。