+ public CassandraReader() {
+ Session inis = CassandraNativeConnector.getSession();
+ setSession(inis);
+ }
+
+ public void setSession(Session s) {
+ assert s != null;
+ session = s;
+ }
+
+ public ResultSet CassandraQuery(String column, String table, String condition) {
+ String com = "SELECT " + column + " FROM " + table + ";";
+ System.out.println("Command: " + com);
+ ResultSet results = session.execute(com);
+ return results;
+ }