Class HadoopReporter

java.lang.Object
fr.ens.biologie.genomique.eoulsan.util.hadoop.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 Details

    • 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 Details

    • 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