org.apache.hadoop.chukwa.extraction.archive

Class ChukwaArchiveDataTypeOutputFormat

java.lang.Object

org.apache.hadoop.mapred.FileOutputFormat<K,V>

org.apache.hadoop.mapred.lib.MultipleOutputFormat<K,V>

org.apache.hadoop.mapred.lib.MultipleSequenceFileOutputFormat<ChukwaArchiveKey,ChunkImpl>

org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDataTypeOutputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.OutputFormat<ChukwaArchiveKey,ChunkImpl>

public class ChukwaArchiveDataTypeOutputFormat
extends org.apache.hadoop.mapred.lib.MultipleSequenceFileOutputFormat<ChukwaArchiveKey,ChunkImpl>

Nested Class Summary

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

org.apache.hadoop.mapred.FileOutputFormat.Counter

Constructor Summary

Constructors

Constructor and Description
ChukwaArchiveDataTypeOutputFormat()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordWriter<ChukwaArchiveKey,ChunkImpl>	getRecordWriter(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable arg3)

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

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

Constructor Detail

ChukwaArchiveDataTypeOutputFormat

public ChukwaArchiveDataTypeOutputFormat()

Method Detail

getRecordWriter

public org.apache.hadoop.mapred.RecordWriter<ChukwaArchiveKey,ChunkImpl> getRecordWriter(org.apache.hadoop.fs.FileSystem fs,
                                                                                         org.apache.hadoop.mapred.JobConf job,
                                                                                         String name,
                                                                                         org.apache.hadoop.util.Progressable arg3)
                                                                                  throws IOException

Specified by:

getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<ChukwaArchiveKey,ChunkImpl>

Overrides:

getRecordWriter in class org.apache.hadoop.mapred.lib.MultipleOutputFormat<ChukwaArchiveKey,ChunkImpl>

Throws:

IOException