2017-01-17 5 views

ответ

0

У меня была аналогичная проблема, и я до сих пор не знаю, возможно ли это. Хотя я могу поделиться небольшим обходным решением. В моем случае я назначил ID всем вершинам. Надеюсь, это поможет

val VertexRDD: RDD[(VertexId, Array[String])] = vfile.map(line => line.split(",")).zipWithIndex().map(_.swap)