Chapter04 编写基本的MapReduce程序(三) 非JAVA语言编写mapreduce程序2

使用Aggregate包使用Streaming,使用该包做聚集统计。

Mapper的输出格式如下:function map \t reduce

Aggregate函数列表:

Chapter04 编写基本的MapReduce程序(三) 非JAVA语言编写mapreduce程序2

Aggreate的使用

Chapter04 编写基本的MapReduce程序(三) 非JAVA语言编写mapreduce程序2

ValueHistogram的使用

Chapter04 编写基本的MapReduce程序(三) 非JAVA语言编写mapreduce程序2