斯卡拉·卡珊德拉

Question

请看下面的代码，让我知道我哪里做错了？

使用：

DSE版本-5.1.0

172.31.16.45:9042连接到测试群集。[cqlsh 5.0.1|Cassandra3.10.0.1652|DSE 5.1.0|CQL规范3.4.4|本地协议v4]使用HELP寻求帮助。

谢谢

Cassandra Table :
cqlsh:tdata> select * from map;

 sno | name
-----+------
   1 |  One
   2 |  Two 

斯卡拉

斯卡拉

斯卡拉

我在这里什么都得不到？甚至没有错误。

Answer 1

你遇到了一个非常常见的火花问题。您的println代码正在远程执行器JVM上执行。这意味着打印输出到JVM进程的执行器的STDOUT。如果您想在打印之前将数据带回驱动程序JVM，您需要一个收集调用。

rdd
 .collect //Change from RDD to local collection
 .foreach(println)