Dataset.groupByKey + reduceGroups

case class Foo(x: String, y: String, z: Int)

val ds = df.as[Foo]
ds.groupByKey(_.x).reduceGroups((a, b) => a.copy(z = a.z + b.z)).explain

 

참고: https://stackoverflow.com/a/32903568/5137193