2014-06-08 21 views
0

請讓我知道,如果我們能關係的特定字段加載到另一個如下圖所示如何將數據傳遞給豬關係

usergroup = GROUP input BY user; 

output = FOREACH usergroup { 
       intermediate = input.traid; 
       distinctdata = DISTINCT intermediate; 

     GENERATE group as user,count(distinctdata); }; 

回答

1

無法關係的特定字段加載到另一個。

根據我的理解,您希望爲input.traid指定不同的值,然後對其進行計數。

在這裏你總是會得到1count(distinctdata)爲每個用戶。你爲什麼要這個輸出?

DISTINCT不適用於特定的列(字段),但用於元組(行)。它刪除重複的元組。