使用Aggregate包使用Streaming,使用该包做聚集统计。 Mapper的输出格式如下:function map \t reduce Aggregate函数列表: Aggreate的使用 ValueHistogram的使用 相关文章: