com.senseidb.indexing.hadoop.reduce
Class IndexUpdateOutputFormat

java.lang.Object
  org.apache.hadoop.mapred.FileOutputFormat<Shard,org.apache.hadoop.io.Text>
      com.senseidb.indexing.hadoop.reduce.IndexUpdateOutputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.OutputFormat<Shard,org.apache.hadoop.io.Text>

public class IndexUpdateOutputFormat
extends org.apache.hadoop.mapred.FileOutputFormat<Shard,org.apache.hadoop.io.Text>

The record writer of this output format simply puts a message in an output path when a shard update is done.

Nested Class Summary

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

org.apache.hadoop.mapred.FileOutputFormat.Counter

Constructor Summary

IndexUpdateOutputFormat()

Method Summary

org.apache.hadoop.mapred.RecordWriter<Shard,org.apache.hadoop.io.Text>

getRecordWriter(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable progress)

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

IndexUpdateOutputFormat

public IndexUpdateOutputFormat()

Method Detail

getRecordWriter

public org.apache.hadoop.mapred.RecordWriter<Shard,org.apache.hadoop.io.Text> getRecordWriter(org.apache.hadoop.fs.FileSystem fs,
                                                                                              org.apache.hadoop.mapred.JobConf job,
                                                                                              String name,
                                                                                              org.apache.hadoop.util.Progressable progress)
                                                                                       throws IOException

Specified by:

getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<Shard,org.apache.hadoop.io.Text>

Specified by:

getRecordWriter in class org.apache.hadoop.mapred.FileOutputFormat<Shard,org.apache.hadoop.io.Text>

Throws:

IOException