文件名称:flambo-cassandra:Flambo (& Spark) 的 Cassandra 绑定
文件大小:11KB
文件格式:ZIP
更新时间:2024-07-26 06:30:33
Clojure
弗兰博-卡桑德拉 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) ) 查看更多测试 执
【文件预览】:
flambo-cassandra-master
----project.clj(729B)
----test()
--------cql.txt(436B)
--------flambo_cassandra()
----LICENSE(11KB)
----src()
--------flambo_cassandra()
----doc()
--------intro.md(123B)
----.gitignore(178B)
----README.md(734B)