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

myCf,
HFactory.createColumn("cellnumber",
eventObj.getCellnumber(), -1,
cassandraMngr.getStringSerializer(),
cassandraMngr.getLongSerializer()));
cassandraMngr.getUUIDMutator().execute();
logger.debug("CDR event with key = " + keyUUID + "
inserted into Cassandra cf " + myCf);
} else {
logger.error("Record not saved. Error while parsing
date to generate KEY for cassandra data store,
column family - " + myCf);
}
}
catch (Exception excep) {
logger.error("Record not saved. Error while saving
data to cassandra data store, column family - " +
myCf, excep);
}
logger.debug("execute method :: End ");
}
}
So here we complete the last piece of the puzzle; we can now stream data into Cassandra
using Storm in real time. Once you execute the topology end to end, you can verify the
data in Cassandra by using the select or list commands on CLI/CQLSH.