@Override

public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {

Cdr cdr = (Cdr) tuple.getValue(0);

cdr.setClientId(Clients.getClientId(cdr.getCallSource()));

basicOutputCollector.emit(new Values(cdr));

System.out.println("CID>> [" + Thread.currentThread().getId() + "]" + cdr);

}

@Override

public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {

outputFieldsDeclarer.declare(new Fields("cdr"));

}