Class ReporterWrapper

  • All Implemented Interfaces:
    org.apache.hadoop.mapred.Reporter, org.apache.hadoop.util.Progressable

    public class ReporterWrapper
    extends org.apache.hadoop.mapreduce.StatusReporter
    implements org.apache.hadoop.mapred.Reporter
    A reporter that works with both mapred and mapreduce APIs.
    • Field Summary

      • Fields inherited from interface org.apache.hadoop.mapred.Reporter

        NULL
    • Constructor Summary

      Constructors 
      Constructor Description
      ReporterWrapper​(org.apache.hadoop.mapred.Reporter reporter)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.hadoop.mapred.Counters.Counter getCounter​(java.lang.Enum<?> anEnum)  
      org.apache.hadoop.mapred.Counters.Counter getCounter​(java.lang.String s, java.lang.String s1)  
      org.apache.hadoop.mapred.InputSplit getInputSplit()  
      float getProgress()  
      void incrCounter​(java.lang.Enum<?> anEnum, long l)  
      void incrCounter​(java.lang.String s, java.lang.String s1, long l)  
      void progress()  
      void setStatus​(java.lang.String s)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ReporterWrapper

        public ReporterWrapper​(org.apache.hadoop.mapred.Reporter reporter)
    • Method Detail

      • getCounter

        public org.apache.hadoop.mapred.Counters.Counter getCounter​(java.lang.Enum<?> anEnum)
        Specified by:
        getCounter in interface org.apache.hadoop.mapred.Reporter
        Specified by:
        getCounter in class org.apache.hadoop.mapreduce.StatusReporter
      • getCounter

        public org.apache.hadoop.mapred.Counters.Counter getCounter​(java.lang.String s,
                                                                    java.lang.String s1)
        Specified by:
        getCounter in interface org.apache.hadoop.mapred.Reporter
        Specified by:
        getCounter in class org.apache.hadoop.mapreduce.StatusReporter
      • incrCounter

        public void incrCounter​(java.lang.Enum<?> anEnum,
                                long l)
        Specified by:
        incrCounter in interface org.apache.hadoop.mapred.Reporter
      • incrCounter

        public void incrCounter​(java.lang.String s,
                                java.lang.String s1,
                                long l)
        Specified by:
        incrCounter in interface org.apache.hadoop.mapred.Reporter
      • getInputSplit

        public org.apache.hadoop.mapred.InputSplit getInputSplit()
                                                          throws java.lang.UnsupportedOperationException
        Specified by:
        getInputSplit in interface org.apache.hadoop.mapred.Reporter
        Throws:
        java.lang.UnsupportedOperationException
      • progress

        public void progress()
        Specified by:
        progress in interface org.apache.hadoop.util.Progressable
        Specified by:
        progress in class org.apache.hadoop.mapreduce.StatusReporter
      • getProgress

        public float getProgress()
      • setStatus

        public void setStatus​(java.lang.String s)
        Specified by:
        setStatus in interface org.apache.hadoop.mapred.Reporter
        Specified by:
        setStatus in class org.apache.hadoop.mapreduce.StatusReporter