long ts1 = System.currentTimeMillis();
logger.debug("event=delete_batch column_family=" + columnFamily);
try {
MutationBatch m = getKeyspace(keyspace).prepareMutationBatch();
if (columnList == null || columnList.isEmpty()) {
for (K k : keyList) {
ColumnListMutation<N> clm = m.withRow((ColumnFamily<K, N>)getColumnFamily(columnFamily), k);
clm.delete();
CMBControllerServlet.valueAccumulator.addToCounter(AccumulatorName.CassandraWrite, 1L);
}
} else {
// TODO: review this logic with jane
for (int i=0; i< keyList.size();i++) {
ColumnListMutation<N> clm = m.withRow((ColumnFamily<K, N>)getColumnFamily(columnFamily), keyList.get(i));
clm.deleteColumn((N)getComposite(columnList.get(i)));
CMBControllerServlet.valueAccumulator.addToCounter(AccumulatorName.CassandraWrite, 1L);
}
}
OperationResult<Void> result = m.execute();
} catch (NotFoundException ex){
//ignore.
} catch (ConnectionException ex) {
throw new PersistenceException(ex);
} finally {