edu.yale.cs.hadoopdb.benchmark
Class JoinTaskDB.Reduce

java.lang.Object
  extended by org.apache.hadoop.mapred.MapReduceBase
      extended by edu.yale.cs.hadoopdb.benchmark.JoinTaskDB.Reduce
All Implemented Interfaces:
java.io.Closeable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Enclosing class:
JoinTaskDB

public static class JoinTaskDB.Reduce
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>


Field Summary
private  double avgPageRank
           
private  org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> foutput
           
private  double maxRevenue
           
private  java.lang.String sourceIP
           
 
Constructor Summary
JoinTaskDB.Reduce()
           
 
Method Summary
 void close()
           
 void reduce(org.apache.hadoop.io.Text key, java.util.Iterator<org.apache.hadoop.io.Text> fields, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> output, org.apache.hadoop.mapred.Reporter reporter)
           
 
Methods inherited from class org.apache.hadoop.mapred.MapReduceBase
configure
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable
configure
 

Field Detail

avgPageRank

private double avgPageRank

foutput

private org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> foutput

maxRevenue

private double maxRevenue

sourceIP

private java.lang.String sourceIP
Constructor Detail

JoinTaskDB.Reduce

public JoinTaskDB.Reduce()
Method Detail

close

public void close()
           throws java.io.IOException
Specified by:
close in interface java.io.Closeable
Overrides:
close in class org.apache.hadoop.mapred.MapReduceBase
Throws:
java.io.IOException

reduce

public void reduce(org.apache.hadoop.io.Text key,
                   java.util.Iterator<org.apache.hadoop.io.Text> fields,
                   org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> output,
                   org.apache.hadoop.mapred.Reporter reporter)
            throws java.io.IOException
Specified by:
reduce in interface org.apache.hadoop.mapred.Reducer<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Throws:
java.io.IOException