git://source.jalview.org
/
proteocache.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Improve stability of Cassandra API calls (commands are checked)
[proteocache.git]
/
datadb
/
compbio
/
cassandra
/
CassandraReaderOld.java
diff --git
a/datadb/compbio/cassandra/CassandraReaderOld.java
b/datadb/compbio/cassandra/CassandraReaderOld.java
index
ff37145
..
6055e60
100644
(file)
--- a/
datadb/compbio/cassandra/CassandraReaderOld.java
+++ b/
datadb/compbio/cassandra/CassandraReaderOld.java
@@
-17,6
+17,7
@@
import compbio.beans.JobBean;
import compbio.beans.ProteinBean;
import compbio.beans.Total;
import compbio.engine.JobStatus;
import compbio.beans.ProteinBean;
import compbio.beans.Total;
import compbio.engine.JobStatus;
+import compbio.engine.Pair;
public class CassandraReaderOld {
private Session session;
public class CassandraReaderOld {
private Session session;
@@
-255,7
+256,6
@@
public class CassandraReaderOld {
int c = 0;
for (Row r : rows) {
String protein = r.getString("Protein");
int c = 0;
for (Row r : rows) {
String protein = r.getString("Protein");
- String id = r.getString("JobID");
if (res.containsKey(protein))
res.put(protein, res.get(protein) + 1);
else
if (res.containsKey(protein))
res.put(protein, res.get(protein) + 1);
else
@@
-284,7
+284,6
@@
public class CassandraReaderOld {
int c = 0;
for (Row r : rows) {
String ip = r.getString("ip");
int c = 0;
for (Row r : rows) {
String ip = r.getString("ip");
- String id = r.getString("JobID");
if (res.containsKey(ip))
res.put(ip, res.get(ip) + 1);
else
if (res.containsKey(ip))
res.put(ip, res.get(ip) + 1);
else