package compbio.beans;
import java.util.HashMap;
-import java.util.LinkedHashMap;
import java.util.Map;
public class DateBean {
package compbio.cassandra;
import java.util.List;
-import java.util.ArrayList;
-import java.util.Collections;
import compbio.beans.JobBean;
import compbio.beans.ProteinBean;
import java.io.BufferedReader;
import java.io.File;
-import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStreamReader;
-import java.net.HttpURLConnection;
-import java.net.MalformedURLException;
import java.io.FileInputStream;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import compbio.data.sequence.FastaSequence;
public class JpredParserLocalFile implements JpredParser {
- private CassandraWriter cw = new CassandraWriter();
private String dirprefix;
public void setSource(String newsourceprefix) {
if (in.matches(date + ":(.*)jp_[^\\s]+")) {
String[] table = in.split("\\s+");
String starttime = table[0];
- String finishtime = table[1];
- String ip = table[2];
String id = table[table.length - 1];
totalcount++;
String confilename = dirprefix + "/" + id + "/" + id + ".concise";
} else {
SimpleDateFormat formatter = new SimpleDateFormat("yyyy/MM/dd");
String dateInString1 = starttime.substring(0, starttime.indexOf(":"));
- long insertdate = 0;
try {
Date dat = formatter.parse(dateInString1);
- insertdate = dat.getTime();
} catch (ParseException e) {
e.printStackTrace();
}
package compbio.engine;
-import compbio.cassandra.Pair;
/**
public JpredJob(String jobid, String date1, String date2) {
super(jobid, date1, date2);
- this.protein = protein;
predictions = new ArrayList<FastaSequence>();
alignment = new ArrayList<FastaSequence>();
log = "";
public JpredJob(String jobid, String date1, String date2, List<FastaSequence> alignment, List<FastaSequence> predictions) {
super(jobid, date1, date2);
- this.protein = protein;
this.alignment = alignment;
this.predictions = predictions;
}
import compbio.cassandra.CassandraNativeConnector;
import compbio.cassandra.CassandraReaderOld;
import compbio.cassandra.DataBase;
-import compbio.cassandra.Pair;
import compbio.engine.JobStatus;
+import compbio.engine.Pair;
public class CassandraRequester {
private CassandraReaderOld db = new CassandraReaderOld();
query.add(db);
}
- /* ???? Very strange code...
- DataBase db = new DataBase();
- db.setTimeTotalExec(totalTime);
- query.add(db);
- */
+ /*
+ * ???? Very strange code... DataBase db = new DataBase();
+ * db.setTimeTotalExec(totalTime); query.add(db);
+ */
return query;
}
/*
* query: total number of jobs for the period from date1 till date2
- */
+ */
public TotalJobsStatisticBean countJobs(String date1, String date2) {
/*
* if (null == date1) { date1 = "1970/1/1"; } if (null == date2) { date1