spark-cassandra-bulkloader:使用 spark 将数据上传到 cassandra 的测试应用程序

时间:2024-07-13 13:14:33
【文件属性】:

文件名称:spark-cassandra-bulkloader:使用 spark 将数据上传到 cassandra 的测试应用程序

文件大小:51KB

文件格式:ZIP

更新时间:2024-07-13 13:14:33

Java

卡桑德拉火花 使用 spark 将数据上传到 cassandra 的测试应用程序,例如使用或 。 此示例中的代码取自 Cassandra 2.0.11,但具有对该项目中输出格式和记录编写器副本的。 笔记 示例数据和 schema.cql 位于 src/main/resources/data 下 用法 将 datastax cassandra 连接器用于 spark spark-submit --master --class uk.co.pinpointlabs.App --input --host --keyspace --table

使用 CqlBulkOutputFormat 使用 datastax cassandra 连接器(当前不起作用) spark-submit --master <mas


【文件预览】:
spark-cassandra-bulkloader-master
----src()
--------main()
----README.md(1KB)
----pom.xml(3KB)
----.gitignore(74B)

网友评论