【文件属性】：
文件名称：flambo-cassandra:Flambo (& Spark) 的 Cassandra 绑定
文件大小：11KB
文件格式：ZIP
更新时间：2021-07-06 12:43:53
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)