Database Reference
In-Depth Information
/**
* Called when {@link ZeroSecondsCDRBolt} is initialized
*/
@Override
public void prepare(Map conf, TopologyContext context,
OutputCollector collector) {
logger.info("prepare method :: Start ");
this.collector = collector;
logger.info("prepare() conf {},Collector {}",
conf.toString(), collector.toString());
logger.info("prepare method :: End ");
}
/**
* Called whenever a new tuple is received by this bolt.
This method
* filters zero duration End records
*/
@
Override
public void execute(Tuple tuple) {
logger.info("execute method :: Start ");
if (tuple != null && tuple.getString(0) != null) {
eventCounter++;
String event = tuple.getString(0);
logger.info("execute :event recd :: {}", event);
if (event != null && event.contains("CALL_END")) {
emitCallEndRecords(tuple);
}
collector.ack(tuple);
}
logger.info("execute method :: End ");
}
private void emitCallEndRecords(Tuple tuple) {
String event = tuple.getString(0);
Search WWH ::




Custom Search