Tamar Fraenkel
unread,Apr 18, 2012, 3:19:02 AM4/18/12Sign in to reply to author
Sign in to forward
You do not have permission to delete messages in this group
Either email addresses are anonymous for this group or you need the view member email addresses permission to view the original message
to hector-users
I created ConfigurableConsistencyLevel with default read and write of
ONE, but with different consistency level for my counter CF, which is
write=TWO and read=ONE.
But when MutationImpe execute runs, and all the mutations are for my
counter family, I see that the method:
public Void execute(Cassandra.Client cassandra) throws Exception {
cassandra.batch_mutate(mutations.getMutationMap(),
ThriftConverter.consistencyLevel(consistencyLevelPolicy.get(operationType)));
return null;
}
reads consistency level ONE.
I see that there is a method:
public HConsistencyLevel get(OperationType op, String cfName) {
if (op == OperationType.READ) {
HConsistencyLevel rcf = readCfConsistencyLevels.get(cfName);
return rcf != null ? rcf : defaultReadConsistencyLevel;
} else {
HConsistencyLevel wcf = writeCfConsistencyLevels.get(cfName);
return wcf != null ? wcf : defaultWriteConsistencyLevel;
}
}
But it is hardly used...
My Questions:
1. Is it a bug?
2. Maybe I can't define different Consistency Levels for different
Column Families?
Thanks,
Tamar