org.apache.hadoop.mapred.lib

Class MultipleTextOutputFormat<K,V>

java.lang.Object

org.apache.hadoop.mapred.FileOutputFormat<K,V>

org.apache.hadoop.mapred.lib.MultipleOutputFormat<K,V>

org.apache.hadoop.mapred.lib.MultipleTextOutputFormat<K,V>

All Implemented Interfaces:

OutputFormat<K,V>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class MultipleTextOutputFormat<K,V>
extends MultipleOutputFormat<K,V>

This class extends the MultipleOutputFormat, allowing to write the output data to different output files in Text output format.

Constructor Summary

Constructors

Constructor and Description
MultipleTextOutputFormat()

Method Summary

Modifier and Type	Method and Description
protected RecordWriter<K,V>	getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3)

Methods inherited from class org.apache.hadoop.mapred.lib.MultipleOutputFormat

generateActualKey, generateActualValue, generateFileNameForKeyValue, generateLeafFileName, getInputFileBasedOutputFileName, getRecordWriter

Methods inherited from class org.apache.hadoop.mapred.FileOutputFormat

checkOutputSpecs, getCompressOutput, getOutputCompressorClass, getOutputPath, getPathForCustomFile, getTaskOutputPath, getUniqueName, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputPath

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipleTextOutputFormat

public MultipleTextOutputFormat()

Method Detail

getBaseRecordWriter

protected RecordWriter<K,V> getBaseRecordWriter(FileSystem fs,
                                                JobConf job,
                                                String name,
                                                Progressable arg3)
                                         throws IOException

Specified by:

getBaseRecordWriter in class MultipleOutputFormat<K,V>

Parameters:

fs - the file system to use

job - a job conf object

name - the name of the file over which a record writer object will be constructed

arg3 - a progressable object

Returns:

A RecordWriter object over the given file

Throws:

IOException