qq_43588139的博客

原创 通过案例快速学会spark的自定义累加器

前言 本文主要是简述如何自定义spark的累加器 案例场景 统计班级中学生的总人数和学生的数学总成绩 代码案例 创建 case class Student case class Student(var count: Int,var math: Int) 创建一个SelfAccumulator的scala类,并且继承AccumulatorV2,同时实现[**isZero(), copy(),re...