【发布时间】:2015-04-27 07:35:59
【问题描述】:
我对 Cassandra 非常陌生,并且使用 cqlsh 来尝试基本查询。我想通过插入具有默认值(例如 0)的新列来更改表。这与this SO question 相同,不同之处在于我尝试从 cqlsh 执行此操作,因此无法在 50,000 行上运行插入命令。有没有“cqlish”方法来实现这一点?
【问题讨论】:
我对 Cassandra 非常陌生,并且使用 cqlsh 来尝试基本查询。我想通过插入具有默认值(例如 0)的新列来更改表。这与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")
【讨论】: