public class StreamSource extends AbstractFlowlet {
static String keyTotal = ":sourceTotal:";
private OutputEmitter<String> output;
CounterTable counters;
public StreamSource() {
<BUG>super("StreamSource");

}
public void process(StreamEvent event, InputContext context) throws CharacterCodingException {
this.counters = getContext().getDataSet(Common.tableName);</BUG>
if (Common.debug) {

public class StreamSource extends AbstractFlowlet {
static String keyTotal = ":sourceTotal:";
private OutputEmitter<String> output;
CounterTable counters;
public StreamSource() {
super("source");
}
public void process(StreamEvent event) {
if (Common.debug) {
