Class DataFileDistCp.DistCpMapper

  • Enclosing class:
    DataFileDistCp

    public static final class DataFileDistCp.DistCpMapper
    extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.Text,​org.apache.hadoop.io.Text>
    This inner class define the mapper class for DataSourceDistCp map-reduce job.
    Author:
    Laurent Jourdren
    • Nested Class Summary

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

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

      Constructors 
      Constructor Description
      DistCpMapper()  
    • Constructor Detail

      • DistCpMapper

        public DistCpMapper()
    • 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.Text,​org.apache.hadoop.io.Text>
        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.Text,​org.apache.hadoop.io.Text>
        Throws:
        IOException
        InterruptedException