package org.commonjava.indy.schedule.datastax;

public class ScheduleDBUtil
{

    public static String getSchemaCreateTableSchedule( String keyspace )
    {
        return "CREATE TABLE IF NOT EXISTS " + keyspace + ".schedule ("
                        + "jobtype varchar,"
                        + "jobname varchar,"
                        + "storekey varchar,"
                        + "scheduletime timestamp,"
                        + "lifescan bigint,"
                        + "expiration varchar,"
                        + "PRIMARY KEY (storekey, jobname)"
                        + ");";
    }

}

@@ -72,16 +72,77 @@
 Util%0A%7B%0A%0A
+    public static final String TABLE_SCHEDULE = %22schedule%22;%0A%0A
     publ
@@ -272,24 +272,38 @@
 ace + %22.
-schedule
+%22 + TABLE_SCHEDULE + %22
  (%22%0A    
@@ -678,10 +678,208 @@
 %0A    %7D%0A%0A
+    public static String getSchemaCreateTypeIndex4Schedule( String keyspace )%0A    %7B%0A        return %22CREATE INDEX IF NOT EXISTS type_idx on %22 + keyspace + %22.%22 + TABLE_SCHEDULE + %22 (jobtype)%22;%0A    %7D%0A%0A
 %7D%0A

Add jobtype as index for schedule