private ScheduledExecutorService localjob_scheduler;
private ScheduledExecutorService update_scheduler;
CassandraNativeConnector db = new CassandraNativeConnector();
- static PropertyHelper ph = ProteoCachePropertyHelperManager.getPropertyHelper();
+ private static PropertyHelper ph = ProteoCachePropertyHelperManager.getPropertyHelper();
private static Logger log = Logger.getLogger(ContextListener.class);
public static boolean READ_WEB_JPRED = false;
public static boolean READ_LOCALFILE_JPRED = false;
FILL_NEWTABLE = initBooleanValue("cassandra.newtables.update");
if (FILL_NEWTABLE) {
+ System.out.println("Initializating new table update scheduler");
update_scheduler = Executors.newSingleThreadScheduledExecutor();
update_scheduler.schedule(new Runnable() {
@Override