课程表

Apache Pig 基础

Apache Pig 诊断运算符

Apache Pig 分组和连接

Apache Pig 合并和拆分

Apache Pig 过滤

Apache Pig 排序

Pig Latin 内置函数

Apache Pig 其他执行模式

工具箱
速查手册

Apache Pig AVG()函数

当前位置:免费教程 » 大数据/云 » Apache Pig

Pig-Latin AVG() 函数用于计算包内数值的平均值。在计算平均值时, AVG() 函数会忽略NULL值。

注意

  • 要获取全局平均值,我们需要执行Group All操作,并使用 AVG() 函数计算平均值。

  • 要获取组的平均值,我们需要使用Group By运算符对其进行分组,然后继续使用average函数。

语法

下面给出了 AVG() 函数的语法。

  1. grunt> AVG(expression)

假设我们在HDFS目录 /pig_data/ 中有一个名为 student_details.txt 的文件,如下所示。

student_details.txt

  1. 001,Rajiv,Reddy,21,9848022337,Hyderabad,89
  2. 002,siddarth,Battacharya,22,9848022338,Kolkata,78
  3. 003,Rajesh,Khanna,22,9848022339,Delhi,90
  4. 004,Preethi,Agarwal,21,9848022330,Pune,93
  5. 005,Trupthi,Mohanthy,23,9848022336,Bhuwaneshwar,75
  6. 006,Archana,Mishra,23,9848022335,Chennai,87
  7. 007,Komal,Nayak,24,9848022334,trivendram,83
  8. 008,Bharathi,Nambiayar,24,9848022333,Chennai,72

通过关系 student_details 将此文件加载到的Pig中,如下所示。

  1. grunt> student_details = LOAD 'hdfs://localhost:9000/pig_data/student_details.txt' USING PigStorage(',')
  2. as (id:int, firstname:chararray, lastname:chararray, age:int, phone:chararray, city:chararray, gpa:int);

计算平均GPA

我们可以使用内置函数 AVG() (区分大小写)来计算一组数值的平均值。让我们使用Group All运算符将关系 student_details 分组,并将结果存储在名为 student_group_all 的关系中,如下所示。

  1. grunt> student_group_all = Group student_details All;

这将产生如下所示的关系。

  1. grunt> Dump student_group_all;
  2. (all,{(8,Bharathi,Nambiayar,24,9848022333,Chennai,72),
  3. (7,Komal,Nayak,24,9848022 334,trivendram,83),
  4. (6,Archana,Mishra,23,9848022335,Chennai,87),
  5. (5,Trupthi,Mohan thy,23,9848022336,Bhuwaneshwar,75),
  6. (4,Preethi,Agarwal,21,9848022330,Pune,93),
  7. (3 ,Rajesh,Khanna,22,9848022339,Delhi,90),
  8. (2,siddarth,Battacharya,22,9848022338,Ko lkata,78),
  9. (1,Rajiv,Reddy,21,9848022337,Hyderabad,89)})

现在让我们使用 AVG() 函数计算所有学生的全球平均GPA,如下所示。

  1. grunt> student_gpa_avg = foreach student_group_all Generate
  2. (student_details.firstname, student_details.gpa), AVG(student_details.gpa);

验证

使用 DUMP 运算子验证关系 student_gpa_avg ,如下所示。

  1. grunt> Dump student_gpa_avg;

输出

它将显示关系 student_gpa_avg 的内容,如下所示。

  1. (({(Bharathi),(Komal),(Archana),(Trupthi),(Preethi),(Rajesh),(siddarth),(Rajiv) },
  2. { (72) , (83) , (87) , (75) , (93) , (90) , (78) , (89) }),83.375)
转载本站内容时,请务必注明来自W3xue,违者必究。
 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号