+ @Override
+ public int jobExists(String jobid) {
+ CassandraNativeConnector dbconnector = new CassandraNativeConnector();
+ JobReader reader = new JobReader();
+ reader.setSession(dbconnector.getSession());
+ if (null != reader.readJobLog(jobid)) {
+ return 1;
+ }
+ return 0;
+ }
+