我使用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)