Package org.elasticsearch.hadoop.mr
Class MultiOutputFormat
java.lang.Object
org.apache.hadoop.mapreduce.OutputFormat
org.elasticsearch.hadoop.mr.MultiOutputFormat
- All Implemented Interfaces:
OutputFormat
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voidaddOutputFormat(Configuration cfg, Class<? extends OutputFormat>... formats) voidcheckOutputSpecs(FileSystem ignored, JobConf job) voidcheckOutputSpecs(JobContext context) getOutputCommitter(TaskAttemptContext context) getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) getRecordWriter(TaskAttemptContext context)
-
Field Details
-
CFG_FIELD
- See Also:
-
-
Constructor Details
-
MultiOutputFormat
public MultiOutputFormat()
-
-
Method Details
-
getRecordWriter
public RecordWriter getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) throws IOException - Specified by:
getRecordWriterin interfaceOutputFormat- Throws:
IOException
-
checkOutputSpecs
- Specified by:
checkOutputSpecsin interfaceOutputFormat- Throws:
IOException
-
getRecordWriter
public RecordWriter getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException - Specified by:
getRecordWriterin classOutputFormat- Throws:
IOExceptionInterruptedException
-
checkOutputSpecs
- Specified by:
checkOutputSpecsin classOutputFormat- Throws:
IOExceptionInterruptedException
-
getOutputCommitter
public OutputCommitter getOutputCommitter(TaskAttemptContext context) throws IOException, InterruptedException - Specified by:
getOutputCommitterin classOutputFormat- Throws:
IOExceptionInterruptedException
-
addOutputFormat
-