1

我有一个正在分组的关系。我怎样才能像地图一样访问分组值?

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)

试了几种组合都没用。

4

1 回答 1

0

据此,似乎是PIG-1798报告错误。

于 2013-11-30T05:57:29.207 回答