通过解析参数上传Cassandra Spark连接器

Spark Cassandra连接器主要用于使用Spark处理卡桑德拉数据。这意味着如果你不使用这些词 Dataset , Dataframe 或 RDD 您可能不需要使用Spark Cassandra连接器。

上面使用的格式在Java驱动程序中有效,该驱动程序是Spark Cassandra连接器的一部分,可以通过 CassandraConnector Documentation

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)")
}