火花（贝壳），卡桑德拉：你好，世界？

Question

import com.datastax.spark.connector.cql.CassandraConnector

CassandraConnector(conf).withSessionDo { session =>
  session.execute("CREATE KEYSPACE test2 WITH REPLICATION = {'class': 'SimpleStrategy', 'replication_factor': 1 }")
  session.execute("CREATE TABLE test2.words (word text PRIMARY KEY, count int)")
}

Maven中央存储库(Spark-Cassandra-Connector-Java2.11)

那么，在本地运行Spark和Cassandra之后，如何创建keyspace、表和插入行呢？

Answer 1

您下载的jar只有Java api，所以它不能与Scala Spark shell一起使用。我建议您按照Spark Cassandra连接器页面上的说明进行操作。

https://github.com/datastax/spark-cassandra-connector/blob/master/doc/13_spark_shell.md

这些指令将使您构建包含所有依赖项的完整程序集jar，并使用--jars将其添加到Spark Shell类路径中。