Switching to TimeWindow Cassandra compaction strategy

lib/include_internal/dcdbglobals.h

@@ -42,6 +42,7 @@
 #define KEYSPACE_NAME        "dcdb"
 #define CF_SENSORDATA        "sensordata"
 #define SENSORDATA_GC_GRACE_SECONDS "600"
+#define SENSORDATA_COMPACTION "{'class' : 'TimeWindowCompactionStrategy', 'compaction_window_unit' : 'DAYS', 'compaction_window_size' : 1 }"
 
 #define CONFIG_KEYSPACE_NAME KEYSPACE_NAME "_config"
 #define CF_PUBLISHEDSENSORS  "publishedsensors"

lib/src/connection.cpp

@@ -488,7 +488,8 @@ bool ConnectionImpl::initSchema() {
       createColumnFamily(CF_SENSORDATA,
           "sid varchar, ws smallint, ts bigint, value bigint",
           "sid, ws, ts",
-          "COMPACT STORAGE AND gc_grace_seconds = " SENSORDATA_GC_GRACE_SECONDS );
+          "COMPACT STORAGE AND gc_grace_seconds = " SENSORDATA_GC_GRACE_SECONDS 
+          " AND compaction = " SENSORDATA_COMPACTION);
   }
 
   if (!existsColumnFamily(CF_VIRTUALSENSORS)) {
@@ -496,7 +497,8 @@ bool ConnectionImpl::initSchema() {
       createColumnFamily(CF_VIRTUALSENSORS,
           "sid varchar, ws smallint, ts bigint, value bigint",
           "sid, ws, ts",
-          "COMPACT STORAGE AND gc_grace_seconds = " SENSORDATA_GC_GRACE_SECONDS );
+          "COMPACT STORAGE AND gc_grace_seconds = " SENSORDATA_GC_GRACE_SECONDS
+          " AND compaction = " SENSORDATA_COMPACTION);
   }
 
   /* Keyspace and column family for job data */