Clojurians
#flambo
<
2016-05-16
>

This page is not created by, affiliated with, or supported by Slack Technologies, Inc.

ccann19:05:24

(defn save-to-cassandra
  [^SQLContext sqlc rdd schema]
  (-> (.createDataFrame sqlc rdd schema)
      (.write)
      (.mode "append")
      (.format "org.apache.spark.sql.cassandra")
      (.options {"keyspace” "foo"
                 "table” "bar"})
      (.save)))