如何用多个字段连接pig中的两个关系

nimxete2 于 2021-06-02 发布在 Hadoop

关注(0)|答案(1)|浏览(255)

我有两个csv文件：
1-fertilliy.csv：

2-预期寿命.csv：

我想加入他们的Pig，这样的结果将是这样的：

我是新来的Pig，我不能得到正确的答案，但这是我的代码：

fertility = LOAD 'fertility' USING org.apache.hcatalog.pig.HCatLoader();

lifeExpectency = LOAD 'lifeExpectency' USING   org.apache.hcatalog.pig.HCatLoader();

A = JOIN fertility by country, lifeExpectency by country; 

B = JOIN fertility by year, lifeExpectency by year; 

C = UNION A,B;

DUMP C;

下面是我的代码的结果：

hadoop hortonworks-sandbox apache-pig

来源：https://stackoverflow.com/questions/46875177/how-to-join-two-relations-in-pig-with-multiple-fields

1条答案

按热度按时间

taor4pac1#

您有按国家和年份的联接，并选择最终输出所需的必要列。

fertility = LOAD 'fertility' USING org.apache.hcatalog.pig.HCatLoader();
lifeExpectency = LOAD 'lifeExpectency' USING   org.apache.hcatalog.pig.HCatLoader();

A = JOIN fertility by (country,year), lifeExpectency by (country,year); 
B = FOREACH A GENERATE  fertility::country,fertility::year,fertility::fertility,lifeExpectency::lifeExpectency;  
DUMP B;

赞(0）回复(0）举报 2021-06-02

我来回答

如何用多个字段连接pig中的两个关系

1条答案

相关问题

热门标签

最新问答