我在CQL3控制檯中創建一個表(沒有單一的主鍵成分是獨一無二的,他們一起將):卡桑德拉/赫:添加計數器上的複合主鍵
CREATE TABLE aggregate_logs (
bpid varchar,
jid int,
month int,
year int,
value counter,
PRIMARY KEY (bpid, jid, month, year));
這才得以更新和查詢使用:
UPDATE aggregate_logs SET value = value + 1 WHERE bpid='1' and jid=1 and month=1 and year=2000;
這符合預期。我想要做的赫克託相同的更新(Scala中):
val aggregateMutator:Mutator[Composite] = HFactory.createMutator(keyspace, compositeSerializer)
val compKey = new Composite()
compKey.addComponent(bpid, stringSerializer)
compKey.addComponent(new Integer(jid), intSerializer)
compKey.addComponent(new Integer(month), intSerializer)
compKey.addComponent(new Integer(year), intSerializer)
aggregateMutator.incrementCounter(compKey, LogsAggregateFamily, "value", 1)
,但我得到一個錯誤與消息:
...HInvalidRequestException: InvalidRequestException(why:String didn't validate.)
運行查詢直接從赫克託有:
val query = new me.prettyprint.cassandra.model.CqlQuery(keyspace, compositeSerializer, stringSerializer, new IntegerSerializer())
query.setQuery("UPDATE aggregate_logs SET value = value + 1 WHERE 'bpid'=1 and jid=1 and month=1 and year=2000")
query.execute()
它給我的錯誤:
InvalidRequestException(why:line 1:59 mismatched input 'and' expecting EOF)
我似乎還沒有其他例子在複合主鍵下使用計數器。它甚至有可能嗎?