且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

在Spark中的RDD中的邻居元素上操作

更新时间:2023-11-18 22:16:46

最有效的解决方案是使用sliding方法:

The most efficient solution is to use sliding method:

import org.apache.spark.mllib.rdd.RDDFunctions._

val rdd = sc.parallelize(Seq(1, 3,-1, 0, 2, -4, 6))
  .sortBy(identity)
  .sliding(2)
  .map{case Array(x, y) => y - x}