Spark-Riak Connector Add-on (Riak TS)
Writing Data

Writing Data To TS Table

Scala

You can save an RDD of type <org.apache.spark.sql.Row> to Riak TS as follows:

val output_ts_table = "test-bucket"
rdd.saveToRiakTS(output_ts_table);

Java

An existing JavaRDD, sqlRdd, can be saved to Riak TS as follows:

SparkJavaUtil.javaFunctions(sqlRdd).saveToRiakTS(TABLE_NAME);