foreach - 如何在 Pig 脚本的 foreach 循环中运行存储并存储在 HDFS 的特定路径中

Question

我需要根据其组存储数据。使用后grouped = group events by (name,type);

当我描述分组时，我得到了这个：

{group: (name: chararray,type: chararray),events: {(eventDate: chararray, name: chararray,type: chararray)}}

例如每个组和元组：

• {("group1name,group1type"),(1,b,c),(2,f,e),(1,4,3)}
• {("group2name,group2type"),(2,d,e)}
• {("group3name,group3type"),(3,r,e),(4,s,e)}

所以我想将 (1,b,c),(2,f,e),(1,4,3) 存储在路径“ group1.name/group1.type/datafile ”, (2,d,e) 中路径“ group2.name/group2.type/datafile ”等等。我怎样才能做到这一点？