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);
                   ....
                }
    }

Reply via email to