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
