2013-06-25 64 views
1

我有一個正在分組的關係。我如何訪問像地圖一樣的分組值?在Pig中過濾分組值

data = load 'log.txt' as (id:chararray,name:chararray); 
grouped = group data by id; 
foreach data { 
filtered = filter group by group.id=data.id; 
}; 

一種方法我試圖迭代組並過濾結果包。但我的情況是我必須迭代一個外部元組,然後這些結果必須從分組值中獲取相應的包。我嘗試過使用嵌套的foreach,但我得到了下面的異常,

expression is not a project expression: (Name: ScalarExpression) Type: null Uid: null) 

試過沒有用的幾種組合。

+0

請顯示您的實際情況,而不是簡單的一個,您已經找到了解決方案。 –

+0

它不清楚你想達到什麼目的。你在過濾什麼?爲什麼你需要在foreach中過濾而不是在foreach之外? –

回答