X-Git-Url: http://source.jalview.org/gitweb/?p=proteocache.git;a=blobdiff_plain;f=datadb%2Fcompbio%2Fcassandra%2Freaders%2FExecutionTimeReader.java;h=bca4666d3f401f3f0ceece72f182a0408a8062c5;hp=6bd17eb15343d1002423fa29ae72d4df44d9342b;hb=061055038b377d55c7327ec0ebb5216b4c6da9ce;hpb=2d0c3af83988ff2a68d789efb4ccf2ff3c65a88a diff --git a/datadb/compbio/cassandra/readers/ExecutionTimeReader.java b/datadb/compbio/cassandra/readers/ExecutionTimeReader.java index 6bd17eb..bca4666 100644 --- a/datadb/compbio/cassandra/readers/ExecutionTimeReader.java +++ b/datadb/compbio/cassandra/readers/ExecutionTimeReader.java @@ -1,8 +1,5 @@ package compbio.cassandra.readers; -import java.text.ParseException; -import java.text.SimpleDateFormat; -import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.List; @@ -10,11 +7,9 @@ import java.util.List; import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Row; +import compbio.beans.DateBean; import compbio.beans.ExecutionTimeBean; -import compbio.beans.Total; import compbio.beans.TotalExecutionTime; -import compbio.beans.TotalJobsStatisticBean; -import compbio.cassandra.DataBase; import compbio.cassandra.DateFormatter; import compbio.cassandra.Pair; @@ -77,6 +72,32 @@ public class ExecutionTimeReader extends CassandraReader { } query.setWholeTotal(wholeTotal); return query; - } + + /** + * query: jobs and sequence at a date with current execution time interval + * + * @param day + * the date in long format + * @param date + * the date in String format + * + * @param interval + * buttom and top bounds of the interval Pair + * @return DateBean to the controller JobController + **/ + public DateBean readJobByDay(long day, String date, Pair interval) { + DateBean res = new DateBean(date); + ResultSet results = CassandraQuery("SELECT * FROM ProteinData WHERE jobtime = " + day + ";"); + if (results == null || results.isExhausted()) + return null; + List rows = results.all(); + for (Row r : rows) { + if (interval.getElement0() <= r.getInt("ExecTime")/1000 && r.getInt("ExecTime")/1000 < interval.getElement1()) + res.setJobidAndSeq(r.getString("JobID"), r.getString("Protein")); + + } + return res; + } + }