我試圖從(使用Scala的2.11)時,Spark 2.1工作中讀取卡桑德拉表(mykeyspace.mytable
):非空星火數據集的foreach不執行
val myDataset = sqlContext
.read
.format("org.apache.spark.sql.cassandra")
.options(Map("table" -> "mytable", "keyspace" -> "mykeyspace"))
.load()
myDataset.show()
println(s"Ping and the count is: ${myDataset.count}")
myDataset.foreach(t => println("Weee"))
println("Pong")
當這個運行時,控制檯輸出:
+--------------+-----------+
| username|modified_at|
+--------------+-----------+
|sluggoo-flibby| null|
+--------------+-----------+
Ping and the count is: 1
Pong
因此,有clearl此表中的一條記錄...... 但爲什麼我foreach
循環「不工作?」爲什麼我看不到我的「Weee」輸出?
你應該告訴你自己關於spark –
的基礎知識謝謝@RaphaelRoth這是一個沒有大多數控制檯實現的twenry胡蘿蔔。 – smeeb