Hi,
I'm using Cloudera's 0.20.2+228 release.
How do I create a custom Counter using the NEW API?
In my Mapper class I tried this:
public class MyMapper extends Mapper<Object, Text, Text, Text> {
....
static enum recordTypes { GOOD, BAD, IGNORED };
public void map(Object key, Text value, Context context)
throws IOException,InterruptedException {
....
Counters myCounters = new Counters();
Counter goodRecs = myCounters.findCounter(recordTypes.GOOD);
Counter badRecs = myCounters.findCounter(recordTypes.BAD);
if (parser.isValidRecord(value.toString())) {
goodRecs.increment(1L);
....
}
}