All you'd need to do is *transform* the rdd before writing it, e.g. using the .map function.
On Thu, Aug 13, 2015 at 11:30 AM, Priya Ch <learnings.chitt...@gmail.com> wrote: > 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 >
