Cassandra 默认列值 cqlsh

Cassandra default column value cqlsh

我是 Cassandra 的新手,使用 cqlsh 尝试基本查询。我想通过插入一个具有默认值(比如 0)的新列来更改 table。这与 this SO question 相同,不同之处在于我试图从 cqlsh 执行此操作,因此不能 运行 在 50,000 行上插入命令。有没有 "cqlish" 方法来实现这个?

目前没有 cqlsh/cql 驱动程序方法可以在不对所有行执行的情况下执行此操作。最简单的方法可能是使用 Spark 和 Cassandra 连接器。

在那里你可以做类似的事情

case class RowObj( oldValue1: Type, ..., newDefaultValue: Type)
sc.cassandraTable[RowObj]("keyspace","table")
    .map(row -> row.copy(newDefaultValue = default)
    .saveToCassandra("keyspace","table")