火花外壳中的RDD输出与打印(RDD)在思想上不同


val rddData1 = sc.makeRDD(1 to 10, 2)
println(rddData1.glom.collect)

想法中的代码或火花壳将输出[[I@34a0ef00

但是火花壳中的rddData1.glom.collect将输出Array[Array[Int]]=Array(Array(1,2,3,4,5(,Array(6,7,8,9,10(

我如何在思想中获得数组[Array[Int]]=数组(数组(1,2,3,4,5(,数组(6,7,8,9,10(

val conf = new SparkConf()
.setMaster("local[*]")
.setAppName("myAppName")
val sc = new SparkContext(conf)
val rddData1 = sc.makeRDD(1 to 10,2)
val rddData2 = sc.makeRDD(20 to 25,2)
println(rddData1.glom().collect())
println(java.util.Arrays.deepToString( rddData1.glom().collect().map(_.asInstanceOf[Object])))
// output [[1, 2, 3, 4, 5], [6, 7, 8, 9, 10]]
// 结束任务
sc.stop()
val conf = new SparkConf()
.setMaster("local[*]")
.setAppName("myAppName")
val sc = new SparkContext(conf)
val rddData1 = sc.makeRDD(1 to 10,2)
println(java.util.Arrays.toString( rddData1.collect()))
// output [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
// 结束任务
sc.stop()

最新更新