flambo cassandra Flambo (& Spark)的Cassandra绑定
弗兰博-卡桑德拉Flambo的Cassandra绑定Flambo是Apache Spark的Clojure DSL如果您使用的是官方spark-cassandra-connector,这些绑定用于处理Cassandra RDD ##TODO写入不支持atm用法(require '[flambo.conf :as conf] '[flambo.api :as f] '[flambo-cassandra.core :as fc] :reload-all) (-> (fc/ctable sc "test" "person") (f/map (f/fn [s] (fc/row->clj s))) (f/collect) )查看更多测试执
用户评论