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)
試過沒有用的幾種組合。
請顯示您的實際情況,而不是簡單的一個,您已經找到了解決方案。 –
它不清楚你想達到什麼目的。你在過濾什麼?爲什麼你需要在foreach中過濾而不是在foreach之外? –