You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/08/17 21:48:33 UTC
[26/38] usergrid git commit: Add consistent read CL for datastax
driver implementations.
Add consistent read CL for datastax driver implementations.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/ff3f7e89
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/ff3f7e89
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/ff3f7e89
Branch: refs/heads/master
Commit: ff3f7e899d81d636eddaa203141ee31ef2da097c
Parents: f28abda
Author: Michael Russo <mr...@apigee.com>
Authored: Sun May 1 17:48:43 2016 +0800
Committer: Michael Russo <mr...@apigee.com>
Committed: Sun May 1 17:48:43 2016 +0800
----------------------------------------------------------------------
.../apache/usergrid/persistence/core/CassandraConfigImpl.java | 2 +-
.../java/org/apache/usergrid/persistence/core/CassandraFig.java | 5 +++++
2 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/ff3f7e89/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
index 5dbf162..e87ebb8 100644
--- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
+++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
@@ -61,7 +61,7 @@ public class CassandraConfigImpl implements CassandraConfig {
this.dataStaxReadCl = com.datastax.driver.core.ConsistencyLevel.valueOf( cassandraFig.getReadCl());
- this.dataStaxReadConsistentCl = com.datastax.driver.core.ConsistencyLevel.valueOf( cassandraFig.getReadCl());
+ this.dataStaxReadConsistentCl = com.datastax.driver.core.ConsistencyLevel.valueOf( cassandraFig.getReadClConsistent());
this.dataStaxWriteCl = com.datastax.driver.core.ConsistencyLevel.valueOf( cassandraFig.getWriteCl() );
http://git-wip-us.apache.org/repos/asf/usergrid/blob/ff3f7e89/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
index d8620be..3c58dfb 100644
--- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
+++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
@@ -33,6 +33,7 @@ public interface CassandraFig extends GuicyFig {
// cassndra properties used by datastax driver
String READ_CL = "cassandra.readcl";
+ String READ_CL_CONSISTENT = "cassandra.readcl.consistent";
String WRITE_CL = "cassandra.writecl";
String STRATEGY = "cassandra.strategy";
String STRATEGY_OPTIONS = "cassandra.strategy.options";
@@ -136,6 +137,10 @@ public interface CassandraFig extends GuicyFig {
@Key(READ_CL)
String getReadCl();
+ @Default("QUORUM")
+ @Key(READ_CL_CONSISTENT)
+ String getReadClConsistent();
+
@Default("LOCAL_QUORUM")
@Key(WRITE_CL)
String getWriteCl();