pegasus.mapreduce.common.io

Class WeightedMatrixOutputFormat.MultiBlockWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.IntWritable,WeightedColumnEntry>

pegasus.mapreduce.common.io.WeightedMatrixOutputFormat.MultiBlockWriter

Enclosing class:

WeightedMatrixOutputFormat

public static class WeightedMatrixOutputFormat.MultiBlockWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.IntWritable,WeightedColumnEntry>

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
void	write(org.apache.hadoop.io.IntWritable blockId, WeightedColumnEntry colEntry)

Methods inherited from class java.lang.Object

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

Method Detail

write

public void write(org.apache.hadoop.io.IntWritable blockId,
                  WeightedColumnEntry colEntry)
           throws java.io.IOException,
                  java.lang.InterruptedException

Specified by:

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

Throws:

java.io.IOException

java.lang.InterruptedException

close

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

Specified by:

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

Throws:

java.io.IOException

java.lang.InterruptedException