Fix schema creation

tjake · Mar 31, 2012 · f7f54e7 · f7f54e7
1 parent e64a2fc
commit f7f54e7
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/lucandra/CassandraUtils.java b/src/lucandra/CassandraUtils.java
@@ -388,8 +388,13 @@ public static void createCassandraSchema() throws IOException
 
         cfs.add(cf);
 
-        KsDef solandraKS = new KsDef().setName(keySpace).setReplication_factor(1).setStrategy_class(
+        Map<String, String> strategyOptions = new HashMap<String, String>();
-                "org.apache.cassandra.locator.SimpleStrategy").setCf_defs(cfs);
+        strategyOptions.put("replication_factor", "1");
+        KsDef solandraKS = new KsDef()
+            .setName(keySpace)
+            .setStrategy_class("org.apache.cassandra.locator.SimpleStrategy")
+            .setStrategy_options(strategyOptions)
+            .setCf_defs(cfs);
 
         CassandraServer cs = new CassandraServer();