Class HadoopReporter

  • All Implemented Interfaces:
    fr.ens.biologie.genomique.kenetre.util.Reporter, fr.ens.biologie.genomique.kenetre.util.ReporterIncrementer

    public class HadoopReporter
    extends Object
    implements fr.ens.biologie.genomique.kenetre.util.Reporter
    This class define a Hadoop reporter.
    Since:
    1.0
    Author:
    Laurent Jourdren
    • Constructor Detail

      • HadoopReporter

        public HadoopReporter​(org.apache.hadoop.mapreduce.TaskInputOutputContext context)
        Constructor. This constructor is used by Hadoop mappers and reducers.
        Parameters:
        context - context to use for counter incrementation
      • HadoopReporter

        public HadoopReporter​(org.apache.hadoop.mapreduce.Counters counters)
        Constructor.
        Parameters:
        counters - counters to use for counter incrementation
    • Method Detail

      • incrCounter

        public void incrCounter​(String counterGroup,
                                String counterName,
                                long amount)
        Specified by:
        incrCounter in interface fr.ens.biologie.genomique.kenetre.util.ReporterIncrementer
      • getCounterValue

        public long getCounterValue​(String counterGroup,
                                    String counterName)
        Specified by:
        getCounterValue in interface fr.ens.biologie.genomique.kenetre.util.Reporter
      • getCounterGroups

        public Set<String> getCounterGroups()
        Specified by:
        getCounterGroups in interface fr.ens.biologie.genomique.kenetre.util.Reporter
      • getCounterNames

        public Set<String> getCounterNames​(String group)
        Specified by:
        getCounterNames in interface fr.ens.biologie.genomique.kenetre.util.Reporter