Class HadoopCompatibleTaskScheduler.HadoopCompatibleMapper

  • Enclosing class:
    HadoopCompatibleTaskScheduler

    public static final class HadoopCompatibleTaskScheduler.HadoopCompatibleMapper
    extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.NullWritable,​org.apache.hadoop.io.NullWritable>
    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

        org.apache.hadoop.mapreduce.Mapper.Context
    • Constructor Detail

      • HadoopCompatibleMapper

        public HadoopCompatibleMapper()
    • Method Detail

      • setup

        protected void setup​(org.apache.hadoop.mapreduce.Mapper.Context context)
                      throws IOException,
                             InterruptedException
        Overrides:
        setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.NullWritable,​org.apache.hadoop.io.NullWritable>
        Throws:
        IOException
        InterruptedException
      • map

        protected void map​(org.apache.hadoop.io.LongWritable key,
                           org.apache.hadoop.io.Text value,
                           org.apache.hadoop.mapreduce.Mapper.Context context)
                    throws IOException,
                           InterruptedException
        Overrides:
        map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.NullWritable,​org.apache.hadoop.io.NullWritable>
        Throws:
        IOException
        InterruptedException