且构网

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

在 Spark 中对 RDD 中的邻居元素进行操作

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

最有效的解决方案是使用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}