foreach中的標量投影無效

Question

嗨，我有一個這樣的豬腳本。在做foreach語句時，它會拋出無效的標量投影錯誤。這裏是我的代碼。

a = load 'file' using PigStorage(':'); 
b = group a by ($1, $7, $11); 
c = foreach b generate flatten(group), COUNT(a) as (cnt: int); 
d = filter c by cnt>1; 
e = foreach d generate flatten(a) ; 

如下所示

<line 6, column 31> Invalid scalar projection: a : A column needs to be projected from a relation for it to be used as a scalar 

該錯誤的任何幫助將不勝感激。

Answer 1

問題是因爲'a'不存在於'd'關係模式中。

描述'd'模式，得到： d：{bytearray，bytearray，bytearray，cnt：int}其中'a'不存在。

在腳本，C關係形成，通過壓平的元素組成的組場和數量的投影中，不包含在關係C.