+ private ResultSet execute(String command) {
+ try {
+ ResultSet results = session.execute(command);
+ return results;
+ } catch (QueryExecutionException e) {
+ String mess = "CassandraWriter: query execution exception...";
+ System.out.println(mess);
+ log.error(mess);
+ log.error(e.getLocalizedMessage(), e.getCause());
+ return null;
+ } catch (QueryValidationException e) {
+ String mess = "CassandraWriter: query validation exception... Command: " + command;
+ System.out.println(mess);
+ log.error(mess);
+ log.error(e.getLocalizedMessage(), e.getCause());
+ return null;
+ }
+ }
+