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 = sc_cass.cassandraTable("tutorial", "user")
#cassandra_rdd.toArray.foreach(println)
cassandra_rdd.

Regards,
Koen

Reply via email to