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

ChukwaArchiveDataTypeOutputFormat()

Method Summary

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

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>