Package 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>

@Public
@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.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapred.FileOutputFormat

FileOutputFormat.Counter

Constructor Summary

Constructors

Constructor	Description
MultipleTextOutputFormat()

Method Summary

Modifier and Type	Method	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, setWorkOutputPath

Methods inherited from class java.lang.Object

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

Constructor Details

MultipleTextOutputFormat

public MultipleTextOutputFormat()

Method Details

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