@InterfaceAudience.Public @InterfaceStability.Stable public class MapFileOutputFormat extends FileOutputFormat<WritableComparable<?>,Writable>
OutputFormat
that writes
MapFile
s.BASE_OUTPUT_NAME, COMPRESS, COMPRESS_CODEC, COMPRESS_TYPE, OUTDIR, PART
Constructor and Description |
---|
MapFileOutputFormat() |
Modifier and Type | Method and Description |
---|---|
static <K extends WritableComparable<?>,V extends Writable> |
getEntry(org.apache.hadoop.io.MapFile.Reader[] readers,
Partitioner<K,V> partitioner,
K key,
V value)
Get an entry from output generated by this class.
|
static org.apache.hadoop.io.MapFile.Reader[] |
getReaders(Path dir,
Configuration conf)
Open the output generated by this format.
|
RecordWriter<WritableComparable<?>,Writable> |
getRecordWriter(TaskAttemptContext context)
Get the
RecordWriter for the given task. |
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath
public MapFileOutputFormat()
public RecordWriter<WritableComparable<?>,Writable> getRecordWriter(TaskAttemptContext context) throws IOException
OutputFormat
RecordWriter
for the given task.getRecordWriter
in class FileOutputFormat<WritableComparable<?>,Writable>
context
- the information about the current task.RecordWriter
to write the output for the job.IOException
public static org.apache.hadoop.io.MapFile.Reader[] getReaders(Path dir, Configuration conf) throws IOException
IOException
public static <K extends WritableComparable<?>,V extends Writable> Writable getEntry(org.apache.hadoop.io.MapFile.Reader[] readers, Partitioner<K,V> partitioner, K key, V value) throws IOException
IOException
Copyright © 2016 Apache Software Foundation. All rights reserved.