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

MultipleTextOutputFormat()

Method Summary

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