public class MultiOutputFormat extends OutputFormat implements OutputFormat
| Constructor and Description |
|---|
MultiOutputFormat() |
| Modifier and Type | Method and Description |
|---|---|
static void |
addOutputFormat(Configuration cfg,
Class<? extends OutputFormat>... formats) |
void |
checkOutputSpecs(FileSystem ignored,
JobConf job) |
void |
checkOutputSpecs(JobContext context) |
OutputCommitter |
getOutputCommitter(TaskAttemptContext context) |
RecordWriter |
getRecordWriter(FileSystem ignored,
JobConf job,
String name,
Progressable progress) |
RecordWriter |
getRecordWriter(TaskAttemptContext context) |
public static final String CFG_FIELD
public RecordWriter getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) throws IOException
getRecordWriter in interface OutputFormatIOExceptionpublic void checkOutputSpecs(FileSystem ignored, JobConf job) throws IOException
checkOutputSpecs in interface OutputFormatIOExceptionpublic RecordWriter getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException
getRecordWriter in class OutputFormatIOExceptionInterruptedExceptionpublic void checkOutputSpecs(JobContext context) throws IOException, InterruptedException
checkOutputSpecs in class OutputFormatIOExceptionInterruptedExceptionpublic OutputCommitter getOutputCommitter(TaskAttemptContext context) throws IOException, InterruptedException
getOutputCommitter in class OutputFormatIOExceptionInterruptedExceptionpublic static void addOutputFormat(Configuration cfg, Class<? extends OutputFormat>... formats)