org.apache.hadoop.mapred
Class MapFileOutputFormat

java.lang.Object
  org.apache.hadoop.mapred.OutputFormatBase
      org.apache.hadoop.mapred.MapFileOutputFormat

All Implemented Interfaces:

OutputFormat

public class MapFileOutputFormat
extends OutputFormatBase

An OutputFormat that writes MapFiles.

Constructor Summary

MapFileOutputFormat()

Method Summary

static Writable	getEntry(MapFile.Reader[] readers, Partitioner partitioner, WritableComparable key, Writable value) Get an entry from output generated by this class.
static MapFile.Reader[]	getReaders(FileSystem ignored, Path dir, Configuration conf) Open the output generated by this format.
RecordWriter	getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) Construct a RecordWriter with Progressable.

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

checkOutputSpecs, getCompressOutput, getOutputCompressorClass, setCompressOutput, setOutputCompressorClass

Methods inherited from class java.lang.Object

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

Constructor Detail

MapFileOutputFormat

public MapFileOutputFormat()

Method Detail

getRecordWriter

public RecordWriter getRecordWriter(FileSystem ignored,
                                    JobConf job,
                                    String name,
                                    Progressable progress)
                             throws IOException

Description copied from interface: OutputFormat

Construct a RecordWriter with Progressable.

Specified by:

getRecordWriter in interface OutputFormat

Specified by:

getRecordWriter in class OutputFormatBase

job - the job whose output is being written

name - the unique name for this part of the output

progress - mechanism for reporting progress while writing to file

Returns:

a RecordWriter

Throws:

IOException

getReaders

public static MapFile.Reader[] getReaders(FileSystem ignored,
                                          Path dir,
                                          Configuration conf)
                                   throws IOException

Open the output generated by this format.

Throws:

IOException

getEntry

public static Writable getEntry(MapFile.Reader[] readers,
                                Partitioner partitioner,
                                WritableComparable key,
                                Writable value)
                         throws IOException

Get an entry from output generated by this class.

Throws:

IOException