public class MultiOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat
implements org.apache.hadoop.mapred.OutputFormat
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CFG_FIELD |
| Constructor and Description |
|---|
MultiOutputFormat() |
| Modifier and Type | Method and Description |
|---|---|
static void |
addOutputFormat(org.apache.hadoop.conf.Configuration cfg,
java.lang.Class<? extends org.apache.hadoop.mapreduce.OutputFormat>... formats) |
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job) |
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) |
org.apache.hadoop.mapreduce.OutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapred.RecordWriter |
getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
java.lang.String name,
org.apache.hadoop.util.Progressable progress) |
org.apache.hadoop.mapreduce.RecordWriter |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
public static final java.lang.String CFG_FIELD
public org.apache.hadoop.mapred.RecordWriter getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
java.lang.String name,
org.apache.hadoop.util.Progressable progress)
throws java.io.IOException
getRecordWriter in interface org.apache.hadoop.mapred.OutputFormatjava.io.IOExceptionpublic void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job)
throws java.io.IOException
checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormatjava.io.IOExceptionpublic org.apache.hadoop.mapreduce.RecordWriter getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws java.io.IOException,
java.lang.InterruptedException
getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormatjava.io.IOExceptionjava.lang.InterruptedExceptionpublic void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
throws java.io.IOException,
java.lang.InterruptedException
checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormatjava.io.IOExceptionjava.lang.InterruptedExceptionpublic org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws java.io.IOException,
java.lang.InterruptedException
getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormatjava.io.IOExceptionjava.lang.InterruptedExceptionpublic static void addOutputFormat(org.apache.hadoop.conf.Configuration cfg,
java.lang.Class<? extends org.apache.hadoop.mapreduce.OutputFormat>... formats)