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

Question

我在 scala 中使用 spark-cassandra-connector，我想将一些条目上传到 table。我已经看到以下使用 python 驱动程序的会话构造的上传方法：

session.execute(
    """
    INSERT INTO users (name, credits, user_id)
    VALUES (%s, %s, %s)
    """,
    ("John O'Reilly", 42, uuid.uuid1())
)

spark-connector 是否支持类似的方式来解析上传中的参数？如果支持，构造会是什么样子？当我测试上述方法时，它不起作用。

Answer 1

Spark Cassandra 连接器主要用于使用 Spark 处理 Cassandra 数据。这意味着如果您不使用 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)")
}

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

Cassandra-Spark Connector uploading by parsing arguments

cql

cassandra

spark-cassandra-connector