Hadoop中CopyMapper.class的源代码以及操作示例是什么？

public void setup(Context context) throws IOException,    InterruptedException {

conf = context.getConfiguration();

 

       targetWorkPath = new Path(conf.get(DistCpConstants.CONF_LABEL_TARGET_WORK_PATH));

    Path    targetFinalPath = new Path(conf.get(

            DistCpConstants.CONF_LABEL_TARGET_FINAL_PATH));

    targetFS =    targetFinalPath.getFileSystem(conf);

 

    if    (targetFS.exists(targetFinalPath) &&    targetFS.isFile(targetFinalPath)) {

         overWrite = true; // When target is an existing file,    overwrite it.

    }

}

 

public void setup(Context context) throws IOException,    InterruptedException {

conf = context.getConfiguration();

 

       targetWorkPath = new Path(conf.get(DistCpConstants.CONF_LABEL_TARGET_WORK_PATH));

    Path    targetFinalPath = new Path(conf.get(

            DistCpConstants.CONF_LABEL_TARGET_FINAL_PATH));

    targetFS =    targetFinalPath.getFileSystem(conf);

 

    if    (targetFS.exists(targetFinalPath) &&    targetFS.isFile(targetFinalPath)) {

         overWrite = true; // When target is an existing file,    overwrite it.

    }

}