扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章将为大家详细讲解有关如何安装和使用Pig框架,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
创新互联建站主要从事成都网站建设、网站设计、网页设计、企业做网站、公司建网站等业务。立足成都服务溆浦,10年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:13518219792
Pig是一个利用mapreduce进行计算的框架。有自己的一套语法Pig latin,可以非常方便的书写计算代码。
1、如何使用Pig?
解压缩之后,修改文件conf/pig.properties,增加两行内容,如下:
fs.default.name=hdfs://hadoop0:9000
mapred.job.tracker=hadoop0:9001
保存退出后,执行bin/pig进行命令行.
2、使用pig完成电信手机号码统计流量例子:
#加载hdfs中的数据
这里的A是别名
A = LOAD '/Kpi' AS (f0:chararray,f1:chararray,f2:chararray,f3:chararray,f4:chararray);
DUMP A; //查看结果A
#过滤A中有用的字段
B = FOREACH A GENERATE f1,f2,f3,f4;
DUMP B; //查看结果B
#对B中的记录按照f1进行分组
C = GROUP B BY f1;
DUMP C; //查看结果C
#对分组后的记录,按照分组字段进行累加
D = FOREACH C GENERATE group , SUM(B.f1),SUM(B.f2),SUM(B.f3);
DUMP D; //查看结果D
#把最后的结果保存到HDFS中
STORE D INTO '/out';
3、以上的Pig命令可以放到一个文件中执行文件内容是如下,执行方式pig kpi.pig
内容如同上面一样。
关于“如何安装和使用Pig框架”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流