0
我有一个RDD格式的每个条目(Long,Array [Double])。例如:Spark:将RDD [(Long,Array [Double])]转换为RDD [(Long,Long,Double)]
val A = sc.parallelize([(0, [5.0, 8.3]), (1, [4.2, 1.2])])
我想变换到窗体:
[(0, 0, 5.0), (0, 1, 8.3), (1, 0, 4.2), (1, 1, 1.2)],
其中在元组中的第二个元素是从数组的值的索引。