org.apache.hadoop.tools.mapred
Class CopyOutputFormat<K,V>

java.lang.Object
  org.apache.hadoop.mapreduce.OutputFormat<K,V>
      org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>
          org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<K,V>
              org.apache.hadoop.tools.mapred.CopyOutputFormat<K,V>

public class CopyOutputFormat<K,V>
extends org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.output.TextOutputFormat

org.apache.hadoop.mapreduce.lib.output.TextOutputFormat.LineRecordWriter<K,V>

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

BASE_OUTPUT_NAME, PART

Constructor Summary

CopyOutputFormat()

Method Summary

void	checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
static org.apache.hadoop.fs.Path	getCommitDirectory(org.apache.hadoop.mapreduce.Job job)
org.apache.hadoop.mapreduce.OutputCommitter	getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
static org.apache.hadoop.fs.Path	getWorkingDirectory(org.apache.hadoop.mapreduce.Job job)
static void	setCommitDirectory(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path commitDirectory)
static void	setWorkingDirectory(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path workingDirectory)

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.TextOutputFormat

getRecordWriter

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

getCompressOutput, getDefaultWorkFile, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath

Methods inherited from class java.lang.Object

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

Constructor Detail

CopyOutputFormat

public CopyOutputFormat()

Method Detail

setWorkingDirectory

public static void setWorkingDirectory(org.apache.hadoop.mapreduce.Job job,
                                       org.apache.hadoop.fs.Path workingDirectory)

setCommitDirectory

public static void setCommitDirectory(org.apache.hadoop.mapreduce.Job job,
                                      org.apache.hadoop.fs.Path commitDirectory)

getWorkingDirectory

public static org.apache.hadoop.fs.Path getWorkingDirectory(org.apache.hadoop.mapreduce.Job job)

getCommitDirectory

public static org.apache.hadoop.fs.Path getCommitDirectory(org.apache.hadoop.mapreduce.Job job)

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                               throws IOException

Overrides:

getOutputCommitter in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>

Throws:

IOException

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
                      throws IOException

Overrides:

checkOutputSpecs in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>

Throws:

IOException