1 package compbio.cassandra;
3 import org.apache.log4j.Logger;
5 import com.datastax.driver.core.ResultSet;
6 import com.datastax.driver.core.Session;
8 public class CassandraReader {
9 private static long earlestDate = 0;
10 private Session session;
11 private static Logger log = Logger.getLogger(CassandraNativeConnector.class);
13 public CassandraReader() {
14 Session inis = CassandraNativeConnector.getSession();
18 public void setSession(Session s) {
23 public ResultSet CassandraQuery(String column, String table, String condition) {
24 String com = "SELECT " + column + " FROM " + table + ";";
25 System.out.println("Command: " + com);
26 ResultSet results = session.execute(com);
31 * find the earliest date in the database
33 public static long earliestDate() {
34 earlestDate = CassandraNativeConnector.getEarliestDateInDB();