小编gop*_*cks的帖子

使用Hector0.8.0时出现问题,请执行addCounter

我使用hector-core 0.8.0-1和Cassandra 0.8.0来测试addCounter操作,但我发现我的代码无法将任何数据插入CF,有人能告诉我原因吗?

StringSerializer ser = StringSerializer.get();
Mutator<String> mutator = HFactory.createMutator(keyspace, ser);

List<HCounterColumn<String>> counterColumns = Arrays.asList(
        HFactory.createCounterColumn("1", 30L, ser),
        HFactory.createCounterColumn("2", 20L, ser)
        );  

for (HCounterColumn c : counterColumns)
{   
    mutator.addCounter("testKey1", "CounterColumn", c); 
    mutator.addCounter("testKey2", "CounterColumn", c); 
}   

mutator.execute();
Run Code Online (Sandbox Code Playgroud)

我在日志中找到以下信息:

> 2011-06-21 17:17:00,025 [Thread-3]
> INFO me.prettyprint.cassandra.hector.TimingLogger
> - Tag                                       Avg(ms) 
>      Min      Max  Std Dev     95th   Count 2011-06-21 17:17:00,030
> [Thread-3] INFO me.prettyprint.cassandra.hector.TimingLogger
> - WRITE.fail_                                  4.84 
>     4.84     4.84     0.00     4.84       1 2011-06-21 17:17:00,031 [Thread-3]
> INFO me.prettyprint.cassandra.hector.TimingLogger
> - …
Run Code Online (Sandbox Code Playgroud)

cassandra hector

1
推荐指数
1
解决办法
622
查看次数

标签 统计

cassandra ×1

hector ×1