scala - 你如何将这个功能性的 java 代码转换为 SparkContext 之上的 scala？

Question

好的，所以我points有List<GeoPoint>

以下代码是使用 java 8 功能 API 编写的。它获取点，为每个点计算其匹配的集群 ，然后将它们按点分组ClusterKey。最终我们得到一个Map<ClusterKey, List<GeoPoint>Here it is：

points.
   parallelStream().unordered().
   collect(groupingByConcurrent(Functions::calcClusterKey))

Answer 1

sc.parallelize(points).groupBy(Functions.calcClusterKey).collect.toMap

对应是相当1：1。