public class MultiOutputFormat extends OutputFormat implements 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(Configuration cfg,
java.lang.Class<? extends OutputFormat>... formats) |
void |
checkOutputSpecs(FileSystem ignored,
JobConf job) |
void |
checkOutputSpecs(JobContext context) |
OutputCommitter |
getOutputCommitter(TaskAttemptContext context) |
RecordWriter |
getRecordWriter(FileSystem ignored,
JobConf job,
java.lang.String name,
Progressable progress) |
RecordWriter |
getRecordWriter(TaskAttemptContext context) |
public static final java.lang.String CFG_FIELD
public RecordWriter getRecordWriter(FileSystem ignored, JobConf job, java.lang.String name, Progressable progress) throws java.io.IOException
getRecordWriter in interface OutputFormatjava.io.IOExceptionpublic void checkOutputSpecs(FileSystem ignored, JobConf job) throws java.io.IOException
checkOutputSpecs in interface OutputFormatjava.io.IOExceptionpublic RecordWriter getRecordWriter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
getRecordWriter in class OutputFormatjava.io.IOExceptionjava.lang.InterruptedExceptionpublic void checkOutputSpecs(JobContext context) throws java.io.IOException, java.lang.InterruptedException
checkOutputSpecs in class OutputFormatjava.io.IOExceptionjava.lang.InterruptedExceptionpublic OutputCommitter getOutputCommitter(TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
getOutputCommitter in class OutputFormatjava.io.IOExceptionjava.lang.InterruptedExceptionpublic static void addOutputFormat(Configuration cfg, java.lang.Class<? extends OutputFormat>... formats)