hadoop - 在 Apache Pig 中取消分组

Question

Apache Pig 是否支持 UNGROUP 操作？我想没有。那么有人可以帮我解决这个问题吗？我有一排表格

1,a-b-c
2,d-e-f
3,g-h

我想将其扩展为表格

1,a
1,b
1,c
2,d
2,e
2,f
3,g
3,h

任何帮助表示赞赏。

Answer 1

您可能应该使用内置函数STRSPLIT将第二个字段拆分为多个标记，然后应用FLATTEN为每个元素创建 1 行。像这样的东西：

A = LOAD 'input.txt' as (id, data);

B = FOREACH A GENERATE id, FLATTEN(STRSPLIT(data,'-'));