Package org.apache.hadoop.mapreduce.lib.output

Class SequenceFileOutputFormat<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<K,V>

org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>

org.apache.hadoop.mapreduce.lib.output.SequenceFileOutputFormat<K,V>

Direct Known Subclasses:

SequenceFileAsBinaryOutputFormat

@Public
@Stable
public class SequenceFileOutputFormat<K,V>
extends FileOutputFormat<K,V>

An OutputFormat that writes SequenceFiles.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

FileOutputFormat.Counter

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

BASE_OUTPUT_NAME, COMPRESS, COMPRESS_CODEC, COMPRESS_TYPE, OUTDIR, PART

Constructor Summary

Constructors

Constructor	Description
SequenceFileOutputFormat()

Method Summary

Modifier and Type	Method	Description
static SequenceFile.CompressionType	getOutputCompressionType(JobContext job)	Get the SequenceFile.CompressionType for the output SequenceFile.
RecordWriter<K,V>	getRecordWriter(TaskAttemptContext context)	Get the RecordWriter for the given task.
protected org.apache.hadoop.io.SequenceFile.Writer	getSequenceWriter(TaskAttemptContext context, Class<?> keyClass, Class<?> valueClass)
static void	setOutputCompressionType(Job job, SequenceFile.CompressionType style)	Set the SequenceFile.CompressionType for the output SequenceFile.

Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat

checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath

Methods inherited from class java.lang.Object

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

Constructor Details

SequenceFileOutputFormat

public SequenceFileOutputFormat()

Method Details

getSequenceWriter

protected org.apache.hadoop.io.SequenceFile.Writer getSequenceWriter(TaskAttemptContext context,
 Class<?> keyClass,
 Class<?> valueClass)
                                                              throws IOException

Throws:

IOException

getRecordWriter

public RecordWriter<K,V> getRecordWriter(TaskAttemptContext context)
                                  throws IOException,
InterruptedException

Description copied from class: OutputFormat

Get the RecordWriter for the given task.

Specified by:

getRecordWriter in class FileOutputFormat<K,V>

Parameters:

context - the information about the current task.

Returns:

a RecordWriter to write the output for the job.

Throws:

IOException

InterruptedException

getOutputCompressionType

public static SequenceFile.CompressionType getOutputCompressionType(JobContext job)

Get the SequenceFile.CompressionType for the output SequenceFile.

Parameters:

job - the Job

Returns:

the SequenceFile.CompressionType for the output SequenceFile, defaulting to SequenceFile.CompressionType.RECORD

setOutputCompressionType

public static void setOutputCompressionType(Job job,
 SequenceFile.CompressionType style)

Set the SequenceFile.CompressionType for the output SequenceFile.

Parameters:

job - the Job to modify

style - the SequenceFile.CompressionType for the output SequenceFile