Может ли функция limitByKey изменить ключ?

Question

Я новичок в зажигании, и, вероятно, у меня нет хорошего понимания сокращения по ключу. Я хочу сохранить идентификатор кластера, ближайший к точке.

distancePointMicrocluster: RDD[Point,(ClusterId: Int, Distance: Double)]

    val nearestClusterToPoint = distancesPointMicrocluster.reduceByKey((x,y) => if (x._2 < y._2) x else y )

Ввод и вывод функции

Answer 1

Проблема была не в функции reduceByKey, а в том, что я не сохранил точки в памяти. В результате я воссоздал очки в каждом действии, и по этой причине pointIds не были одинаковыми.