package com.cloudera.flume.reporter.histogram;
import java.io.IOException;
import com.cloudera.flume.core.Event;
import com.cloudera.flume.core.EventSink;
import com.cloudera.flume.reporter.ReportEvent;
import com.cloudera.flume.reporter.charts.ChartPackage;
import com.cloudera.util.Histogram;
Histogram<String> h;
final String name;
this.name = name;
this.h = new Histogram<String>();
}
abstract public String (Event e);
@Override
public void append(Event e)
throws IOException {
String t = extract(e);
if (t != null) {
h.increment(t);
super.append(e);
}
}
@Override
return name;
}
@Override
String report = (ChartPackage.createHistogramGen().generate(h) + "<pre>"
+ name + "\n" + h + "</pre>");
return ReportEvent.createLegacyHtmlReport(name, report);
}
return h;
}
}