Создание СДР из объекта KDNode - PullRequest
Новая
       9

Создание СДР из объекта KDNode

0 голосов
/ 19 декабря 2018

Я использовал функцию kdtree для построения kdtree из последовательности значений Double.Мой вывод имеет тип Option [kdtree.KDNode [T]].Например, с учетом следующей последовательности: 

val pointsArray=Seq((0.076994867,0.298298413),(0.086327576,0.300527564), (0.069019641,0.333370483),(0.119755652,0.298447022),(0.1261188, 0.29859563),(0.072243671,0.346745435),(0.131633643,0.29993313),(0.074958637,0.378102246))

kd-дерево построено следующим образом: 

KDNode(List(0.086327576, 0.300527564),Some(KDNode(List(0.072243671, 0.346745435),Some(KDNode(List(0.076994867, 0.298298413),Some(KDNode(List(0.069019641, 0.333370483),None,None,1)),None,0)),Some(KDNode(List(0.074958637, 0.378102246),None,None,0)),1)),Some(KDNode(List(0.1261188, 0.29859563),Some(KDNode(List(0.119755652, 0.298447022),None,None,0)),Some(KDNode(List(0.131633643, 0.29993313),None,None,0)),1)),0)

Я хочу сохранить этот вывод как СДР и разбить его на различные узлы вСпарк.Но когда я пытаюсь распараллелить его, вызвав sc.parallelize (tree), я получаю следующую ошибку: Несоответствие типов, ожидаемое: Seq [NotInferedT], фактическое: Option [kdtree.KDNode [T]].

Как я могу определить структуру kdtree, чтобы ее можно было использовать в Spark?Спасибо.

...