Adding NoSQL Persistence to Storm - Real-time Analytics with Storm and Cassandra - page 142

logger.error("Error while instantiating
CassandraBolt", e);
throw new RuntimeException(e);
}
}
@Override
public void execute(Tuple input,
BasicOutputCollector collector) {
logger.debug("execute method :: Start ");
Calendar tCalendar = null;
long eventts =
eventObj.getEventTimestampMillis();
com.eaio.uuid.UUID uuid = new
com.eaio.uuid.UUID(getTimeForUUID(eventts),
clockSeqAndNode);
java.util.UUID keyUUID =
java.util.UUID.fromString(uuid.toString());
/*
* Persisting to my CF
*/
try {
if (keyUUID != null) {
cassandraMngrTDR.getUUIDMutator().addInsertion(
keyUUID,
myCf,
HFactory.createColumn("eventts",
new
Timestamp(tCalendar.getTimeInMillis()), -1,
cassandraMngr.getStringSerializer(),
cassandraMngr.getDateSerializer()));
}
cassandraMngrTDR.getUUIDMutator().addInsertion(
keyUUID,