cassandra - Hector为 super cf的子列做incrementCounter

标签 cassandra hector

目前,更改器(mutator)似乎仅适用于标准 cf。是否有其他方法可以在 super cf 的子列上执行incrementCounter?

最佳答案

一小段代码来增加 superColumn 的计数器

使用带有字符串键、超名和名称的 SuperColumns...

String key = "keyOfRow"; 
    String superColumnFamily = "foo"; 
    String superColumnName ="bar"; 
    StringSerializer ss = StringSerializer.get(); 
    // let's insert a couple of counter columns in a superColumn 
    String columnName1="aaa"; 
    String columnName2="bbb"; 
    List <HCounterColumn<String>> myCounters = new 
ArrayList<HCounterColumn<String>>(); 
    myCounters.add(HFactory.createCounterColumn(columnName1, 1L)); 
    myCounters.add(HFactory.createCounterColumn(columnName2, 42L)); 
    Mutator mutator = HFactory.createMutator(keyspace, 
StringSerializer.get()); 
    mutator.insertCounter(key,superColumnFamily , 
HFactory.createCounterSuperColumn(superColumnName, myCounters, ss, 
ss)); 
mutator.execute();

关于cassandra - Hector为 super cf的子列做incrementCounter,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7871091/

相关文章:

python - cqlengine (Cassandra 2.0) 上的错误时间戳

cassandra - Spark+cassandra java.lang.ClassNotFoundException : com. datastax.spark.connector.rdd.CassandraRDD

c# - Hector 中的 KeySpace 和 KeySpace 定义有什么区别?

cassandra - 如何使用 cassandra-cli 或 Hector 设置列族的一致性级别

cassandra - 如何使用 Hector 重新连接到 Cassandra?

Cassandra 在写入/更新之前读取

hadoop - Hbase行键过滤器,范围扫描和cassandra功能

java - 使用 Datastax CQL 驱动程序插入 Cassandra 时设置 TTL

java - 如何使用多个行键从 cassandra 中的计数器列获取值?

java - Cassandra ·赫克托 : How to retrieve all keyrows value in family?