org.apache.hadoop.tools.distcp2.mapred

类 CopyMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<Text,FileStatus,Text,Text>

org.apache.hadoop.tools.distcp2.mapred.CopyMapper

public class CopyMapper
extends Mapper<Text,FileStatus,Text,Text>

Mapper class that executes the DistCp copy operation. Implements the o.a.h.mapreduce.Mapper<> interface.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	CopyMapper.Counter Hadoop counters for the DistCp CopyMapper.

从类继承的嵌套类/接口 org.apache.hadoop.mapreduce.Mapper

Mapper.Context

构造器概要

构造器

构造器和说明
CopyMapper()

方法概要

方法

限定符和类型	方法和说明
void	map(Text relPath, FileStatus sourceFileStatus, Mapper.Context context) Implementation of the Mapper<>::map().
void	setup(Mapper.Context context) Implementation of the Mapper::setup() method.

从类继承的方法 org.apache.hadoop.mapreduce.Mapper

cleanup, run

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

CopyMapper

public CopyMapper()

方法详细资料

setup

public void setup(Mapper.Context context)
           throws IOException,
                  InterruptedException

Implementation of the Mapper::setup() method. This extracts the DistCp- options specified in the Job's configuration, to set up the Job.

覆盖:

setup 在类中 Mapper<Text,FileStatus,Text,Text>

参数:

context - Mapper's context.

抛出:

IOException - On IO failure.

InterruptedException - If the job is interrupted.

map

public void map(Text relPath,
       FileStatus sourceFileStatus,
       Mapper.Context context)
         throws IOException,
                InterruptedException

Implementation of the Mapper<>::map(). Does the copy.

覆盖:

map 在类中 Mapper<Text,FileStatus,Text,Text>

参数:

relPath - The target path.

sourceFileStatus - The source path.

抛出:

IOException

InterruptedException