X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=server%2Fcompbio%2Fstatistic%2FCassandraRequester.java;h=f4c4c18fa37105fc947a86d0a3e9580efc866784;hb=b154a542bd08371e3bcc7d92d0ded1c638399087;hp=72ec074fb0beb7ae7115831c138d4382ff5fac8f;hpb=4458e44cf92e699159ee1257b1bea6300a9abebe;p=proteocache.git

diff --git a/server/compbio/statistic/CassandraRequester.java b/server/compbio/statistic/CassandraRequester.java
index 72ec074..f4c4c18 100755
--- a/server/compbio/statistic/CassandraRequester.java
+++ b/server/compbio/statistic/CassandraRequester.java
@@ -235,6 +235,26 @@ public class CassandraRequester {
 		return query;
 	}
 	
+	/* 
+	 * query ip with number of jobs
+	 */
+	public List<DataBase> readIpByCounter(Integer minimalcounter) {
+		query = new ArrayList<DataBase>();
+		Map<String, Integer> map = db.ReadIpByCounter();
+		if (minimalcounter == null)
+			minimalcounter = 0;
+		if (map == null)
+			return null;
+		for (Map.Entry<String, Integer> entry : map.entrySet()) {
+			if (entry.getValue() > minimalcounter) {
+				DataBase bean = new DataBase();
+				bean.setTotalId(entry.getValue());
+				bean.setIp(entry.getKey());
+				query.add(bean);
+			}
+		}
+		return query;
+	}
 	/*
 	 * query jobs log info
 	 */
@@ -249,6 +269,31 @@ public class CassandraRequester {
 		return query;
 	}
 	
+	
+	/*
+	 * query jobs by ipStructureJobLog
+	 */
+	public List<DataBase> readIp(String ip) {
+		if (ip == null)
+			return null;
+		List<Pair<String, String>> res = db.ReadIpWithJobs(ip);
+	//	System.out.println(res.size());
+		if (res == null) 
+			return null;
+		query = new ArrayList<DataBase>();
+		for (Pair<String, String> entry : res) {	
+			System.out.println("ip " + ip);
+			System.out.println("id " + entry.getElement0());
+			DataBase bean = new DataBase();
+			bean.setIp(ip);
+			bean.setId(entry.getElement0());
+			bean.setProt(entry.getElement1());
+			query.add(bean);
+		}
+		System.out.println(query.size());
+		return query;
+	}
+	
 	/*
 	 * create list of parts of protein sequence;
 	 */