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 <jbel...@apache.org> Authored: Tue Jul 30 09:23:56 2013 -0500 Committer: Jonathan Ellis <jbel...@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"));
