cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [1/3] git commit: add ConfigHelper setters for consistency levels patch by Manoj Mainali; reviewed by jbellis for CASSANDRA-5827
Date Tue, 30 Jul 2013 14:24:22 GMT
Updated Branches:
  refs/heads/cassandra-1.2 e7ea389a3 -> af1a9fef2
  refs/heads/trunk 6b3b62f98 -> 318b00e25


add ConfigHelper setters for consistency levels
patch by Manoj Mainali; reviewed by jbellis for CASSANDRA-5827


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/af1a9fef
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/af1a9fef
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/af1a9fef

Branch: refs/heads/cassandra-1.2
Commit: af1a9fef29be8220973834f89b21bd539efdf055
Parents: e7ea389
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Tue Jul 30 09:23:56 2013 -0500
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Tue Jul 30 09:23:56 2013 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/hadoop/ConfigHelper.java | 10 ++++++++++
 1 file changed, 10 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/af1a9fef/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
index 36228cf..a109b2f 100644
--- a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
+++ b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
@@ -385,11 +385,21 @@ public class ConfigHelper
         return conf.get(READ_CONSISTENCY_LEVEL, "ONE");
     }
 
+    public static void setReadConsistencyLevel(Configuration conf, String consistencyLevel)
+    {
+        conf.set(READ_CONSISTENCY_LEVEL, consistencyLevel);
+    }
+
     public static String getWriteConsistencyLevel(Configuration conf)
     {
         return conf.get(WRITE_CONSISTENCY_LEVEL, "ONE");
     }
 
+    public static void setWriteConsistencyLevel(Configuration conf, String consistencyLevel)
+    {
+        conf.set(WRITE_CONSISTENCY_LEVEL, consistencyLevel);
+    }
+
     public static int getInputRpcPort(Configuration conf)
     {
         return Integer.parseInt(conf.get(INPUT_THRIFT_PORT, "9160"));


Mime
View raw message