cassandra - 使用 spring-data 对反应式 cassandra 进行批量操作

Question

我有以下数据结构（伪代码）：

class GroupedData
{
  String key;
  List<Tuple<String, String>> records;
}

我认为最好的建模方法是做类似的事情

@Table(name="record_by_group)
class DataWithGroup{
  @PrimaryKey(name="group_key")
  String groupKey;
  @PrimaryKey(name="data_key"
  String dataKey;
  String data;
}

然后，我将使用内部弹簧将其流式传输GroupedData到DataWithGroup使用批处理操作中。我在 webflux 应用程序中执行此操作，所以我使用反应式 cassandra 存储库，我注意到有一个 vanillaCassandraBatchOperations但没有ReactiveCassandraBatchOperations. 我想知道我是否遗漏了某些东西，或者有没有办法反应性地插入批处理。或者，我如何将结构类似于 cassandra 的东西插入GroupedData到 cassandra 中，我认为我应该使用复合列，但我无法真正理解它们，更不用说弄清楚如何使用 spring-data 映射它们了。

标签： cassandracassandra-3.0reactivespring-data-cassandra