Spark-Cassandra-connector:即时添加列

Question

以下 cqlsh 命令将一列添加到已经存在的 cassandra 表中。

cqlsh:demodb> ALTER TABLE users ADD coupon_code varchar;

我将如何使用 scala spark-cassandra-connector 做同样的事情？

我在文档中没有看到参考。

另外：com.datastax.spark.connector有斯卡拉多克吗？

Answer 1

您可以使用withSessionDo CassandraConnector的方法，如下所示：

import com.datastax.spark.connector.cql.CassandraConnector
CassandraConnector(conf).withSessionDo { session =>
   session.execute("ALTER TABLE users ADD coupon_code varchar;")
}

在文档中查看更多示例 火花卡桑德拉连接器...