Hi All,

 I have a question in writing rdd to cassandra. Instead of writing entire
rdd to cassandra, i want to write individual statement into cassandra
beacuse there is a need to perform to ETL on each message ( which requires
checking with the DB).
How could i insert statements individually? Using
CassandraConnector.session ??

If so, what is the performance impact of this ? How about using
sc.parallelize() for eah message in the rdd and then insert into cassandra ?

Thanks,
Padma Ch

Reply via email to