文件名称:datastax-spark-csv-importer:示例项目展示了如何使用 Spark 将 CSV 文件导入到 Cassandra 表中
文件大小:19KB
文件格式:ZIP
更新时间:2024-07-01 00:44:46
Scala
Cassandra CSV 导入 w.Spark 示例 在过去的几个月里,我被问过几次,是否有一种方法可以将 CSV 文件导入到 Cassandra 中而无需做太多工作。 有许多不同的策略,但我想我会考虑使用 Spark 来做到这一点。 允许导入 CSV 文件以创建 Spark RDD。 结合这使得导入变得简单,只需要很少的代码。 此示例会提示您从命令行输入 csv 文件的名称并将其导入到 Cassandra 中。 该示例当前写入名为products的 CQL 表,其中包含以下列: id [int] 代码 [文本] 描述 [文本] 启用[布尔值] 1 叉子 叉形把手 真的 2 足部 脚踏泵 真的 ... ... ... ... 显然,您可以自定义它以满足您的需求。 设置 要开始使用 cqlsh 和提供的 DDL 脚本针对您选择的 Cassandra 实例(本地或远程
【文件预览】:
datastax-spark-csv-importer-master
----project()
--------build.properties(20B)
--------plugins.sbt(96B)
----src()
--------universal()
--------main()
----build.properties(20B)
----create-demo.cql(224B)
----sample-products.csv(158B)
----LICENSE(11KB)
----build.sbt(1KB)
----README.md(4KB)
----.gitignore(23B)