Hi,
I am trying to insert into the following column family using Spark Cassandra
connector.
CREATE TABLE myks.mycf (
id bigint,
msg text,
type text,
ts, timestamp,
primary key (id, msg)
)
Is there a way to to have the ts field automatically generate :
// dataRdd is of Type RDD[(Int,String,String)]. Would like the ts field
automatically filled in with value from now().
dataRdd.saveToCassandra(keySpace, cf, SomeColumns("id", "msg", "type"))
Do I need to implement my own RowWriterFactor ?
Thanks in advance for any assistance !
Shing