fix default bloom_filter_fp_chance for LeveledCompactionStrategy;
patch by Aleksey Yeschenko, reviewed by Jonathan Ellis for
CASSANDRA-5093


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

Branch: refs/heads/cassandra-1.2
Commit: 1772b1c2ecea1f2a167aef2c572d5543cd3ea4a0
Parents: 14d62ab
Author: Aleksey Yeschenko <alek...@apache.org>
Authored: Fri Dec 28 18:29:19 2012 +0300
Committer: Aleksey Yeschenko <alek...@apache.org>
Committed: Fri Dec 28 18:29:19 2012 +0300

----------------------------------------------------------------------
 CHANGES.txt                                        |    1 +
 src/java/org/apache/cassandra/cql3/CFPropDefs.java |   22 ++-------------
 2 files changed, 4 insertions(+), 19 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/1772b1c2/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 31563c6..f83009e 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,6 +1,7 @@
 1.2.0
  * Disallow counters in collections (CASSANDRA-5082)
  * cqlsh: add unit tests (CASSANDRA-3920)
+ * fix default bloom_filter_fp_chance for LeveledCompactionStrategy 
(CASSANDRA-5093)
 
 
 1.2.0-rc2

http://git-wip-us.apache.org/repos/asf/cassandra/blob/1772b1c2/src/java/org/apache/cassandra/cql3/CFPropDefs.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/CFPropDefs.java 
b/src/java/org/apache/cassandra/cql3/CFPropDefs.java
index de613a3..2cbcfde 100644
--- a/src/java/org/apache/cassandra/cql3/CFPropDefs.java
+++ b/src/java/org/apache/cassandra/cql3/CFPropDefs.java
@@ -23,10 +23,9 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import org.apache.cassandra.config.CFMetaData;
+import org.apache.cassandra.db.compaction.AbstractCompactionStrategy;
 import org.apache.cassandra.exceptions.ConfigurationException;
 import org.apache.cassandra.exceptions.SyntaxException;
-import org.apache.cassandra.db.ConsistencyLevel;
-import org.apache.cassandra.db.compaction.AbstractCompactionStrategy;
 import org.apache.cassandra.io.compress.CompressionParameters;
 
 public class CFPropDefs extends PropertyDefinitions
@@ -117,7 +116,6 @@ public class CFPropDefs extends PropertyDefinitions
         cfm.minCompactionThreshold(toInt(KW_MINCOMPACTIONTHRESHOLD, 
getCompactionOptions().get(KW_MINCOMPACTIONTHRESHOLD), 
cfm.getMinCompactionThreshold()));
         cfm.maxCompactionThreshold(toInt(KW_MAXCOMPACTIONTHRESHOLD, 
getCompactionOptions().get(KW_MAXCOMPACTIONTHRESHOLD), 
cfm.getMaxCompactionThreshold()));
         cfm.caching(CFMetaData.Caching.fromString(getString(KW_CACHING, 
cfm.getCaching().toString())));
-        cfm.bloomFilterFpChance(getDouble(KW_BF_FP_CHANCE, 
cfm.getBloomFilterFpChance()));
 
         if (compactionStrategyClass != null)
         {
@@ -125,26 +123,12 @@ public class CFPropDefs extends PropertyDefinitions
             cfm.compactionStrategyOptions(new HashMap<String, 
String>(getCompactionOptions()));
         }
 
+        cfm.bloomFilterFpChance(getDouble(KW_BF_FP_CHANCE, 
cfm.getBloomFilterFpChance()));
+
         if (!getCompressionOptions().isEmpty())
             
cfm.compressionParameters(CompressionParameters.create(getCompressionOptions()));
     }
 
-    public ConsistencyLevel getConsistencyLevel(String key) throws 
ConfigurationException, SyntaxException
-    {
-        String value = getSimple(key);
-        if (value == null)
-            return null;
-
-        try
-        {
-            return Enum.valueOf(ConsistencyLevel.class, value);
-        }
-        catch (IllegalArgumentException e)
-        {
-            throw new ConfigurationException(String.format("Invalid 
consistency level value: %s", value));
-        }
-    }
-
     @Override
     public String toString()
     {

Reply via email to