与 Pig 中的字段中的多个存储值交互

Question

我目前正在处理 pig 中包含多个值的字段。我希望按位置按产品统计用户，我使用LOAD 创建以下格式的数据：(Location, {(product1), (product2), (product3)}, numOfUsers)。我希望将每个产品分开并将它们视为单独的实体，这意味着我希望得到以下结果：

(location, (product1), numOfUsers)
(location, (product2), numOfUsers)
(location, (product3), numOfUsers)

我相信我需要使用某种嵌套的FOREACH 函数，但我有点迷茫。包含在同一元组中的每个产品的用户数将是相同的，因为它们是分组的，这很好。我是一个初学者（3 天前从 Pig 开始），所以任何指导将不胜感激。我相信我会使用FLATTEN？

Answer 1

FOREACH A GENERATE location, FLATTEN(products) AS product, numOfUsers;

解决了这个问题。这创建了存储在包中的所有记录的交叉产品。使用http://www.st.ewi.tudelft.nl/~hauff/BDP-Lectures/9_10_advanced_pig.pdf 供参考。非常有用的资源。