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
protected String	generateFileNameForKeyValue(ChukwaArchiveKey key, ChunkImpl chunk, String name)
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.lib.MultipleSequenceFileOutputFormat

getBaseRecordWriter

Methods inherited from class org.apache.hadoop.mapred.lib.MultipleOutputFormat

generateActualKey, generateActualValue, generateLeafFileName, getInputFileBasedOutputFileName

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

clone, equals, finalize, 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

generateFileNameForKeyValue

protected String generateFileNameForKeyValue(ChukwaArchiveKey key,
                                             ChunkImpl chunk,
                                             String name)

Overrides:

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