org.apache.giraph.bsp

Class BspRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

org.apache.giraph.bsp.BspRecordWriter

public class BspRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Used by BspOutputFormat since some versions of Hadoop require that a RecordWriter is returned from getRecordWriter. Does nothing, except insures that write is never called.

Constructor Summary

Constructors

Constructor and Description
BspRecordWriter()

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
void	write(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text value)

Methods inherited from class java.lang.Object

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

Constructor Detail

BspRecordWriter

public BspRecordWriter()

Method Detail

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws IOException,
                  InterruptedException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException

write

public void write(org.apache.hadoop.io.Text key,
                  org.apache.hadoop.io.Text value)
           throws IOException,
                  InterruptedException

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException