hadoop在条件下使用pig语言添加额外的行?

xvw2m8pv  于 2021-06-03  发布在  Hadoop
关注(0)|答案(0)|浏览(217)

有人能帮我编写hadoop脚本吗?基本上,我要做的是填充缺失的年份,以填写每年的数据。我不知道怎样才能恰当地填补这段缺失的岁月。实际数据:

(Zambia, 2004, Health management & support workers, 0.994)
(Zambia, 2005, Health management & support workers, 0.033)
(Zambia, 2006, Health management & support workers, 0.928)
(Zambia, 2009, Health management & support workers, 0.071)
(Zambia, 2010, Health management & support workers, 0.036)

我想要的是:

(Zambia, 2001, Health management & support workers, 0.994)
(Zambia, 2002, Health management & support workers, 0.994)
(Zambia, 2003, Health management & support workers, 0.994)
(Zambia, 2004, Health management & support workers, 0.994)
(Zambia, 2005, Health management & support workers, 0.033)
(Zambia, 2006, Health management & support workers, 0.928)
(Zambia, 2007, Health management & support workers, 0.071)
(Zambia, 2008, Health management & support workers, 0.071)
(Zambia, 2009, Health management & support workers, 0.071)
(Zambia, 2010, Health management & support workers, 0.036)
(Zambia, 2011, Health management & support workers, 0.036)
(Zambia, 2012, Health management & support workers, 0.036)

这是我的密码:
b=负载'/双芯/标称'as(country:chararray, year:int, job:chararray,珀特nthpeople:float); //加载上面显示的数据
c=b组(按国家、职务);
插入代码>>>
将结果存储到“/dualcore/nomnomready”中;
非常感谢您的帮助。谢谢!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题