com.nhncorp.neptune.util.matrix
Class MatrixMutiplyReduce

java.lang.Object
  com.nhncorp.neptune.util.matrix.MatrixMutiplyReduce

All Implemented Interfaces:

org.apache.hadoop.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

public class MatrixMutiplyReduce
extends java.lang.Object
implements org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Constructor Summary

MatrixMutiplyReduce()

Method Summary

void	close()
void	configure(org.apache.hadoop.mapred.JobConf job)
void	reduce(org.apache.hadoop.io.WritableComparable key, java.util.Iterator<org.apache.hadoop.io.Writable> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> colletcor, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class java.lang.Object

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

Constructor Detail

MatrixMutiplyReduce

public MatrixMutiplyReduce()

Method Detail

reduce

public void reduce(org.apache.hadoop.io.WritableComparable key,
                   java.util.Iterator<org.apache.hadoop.io.Writable> values,
                   org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> colletcor,
                   org.apache.hadoop.mapred.Reporter reporter)
            throws java.io.IOException

Specified by:

reduce in interface org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

java.io.IOException

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

close

public void close()
           throws java.io.IOException

Specified by:

close in interface org.apache.hadoop.io.Closeable

Throws:

java.io.IOException