Hello,
I'm trying to read data from a table stored in cassandra with pyspark.
I found the scala code to loop through the table :
cassandra_rdd.toArray.foreach(println)
How can this be translated into PySpark ?
code snipplet :
sc_cass = CassandraSparkContext(conf=conf)
cassandra_rdd =
On Fri, Jun 19, 2015 at 7:33 AM, Koen Vantomme koen.vanto...@gmail.com wrote:
Hello,
I'm trying to read data from a table stored in cassandra with pyspark.
I found the scala code to loop through the table :
cassandra_rdd.toArray.foreach(println)
How can this be translated into PySpark ?