public static class ABtDenseOutJob.QRReducer extends org.apache.hadoop.mapreduce.Reducer<SplitPartitionedWritable,DenseBlockWritable,SplitPartitionedWritable,VectorWritable>
Modifier and Type | Field and Description |
---|---|
protected int |
blockHeight |
protected int |
lastTaskId |
protected org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,DenseBlockWritable> |
qhatCollector |
protected QRFirstStep |
qr |
protected org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,VectorWritable> |
rhatCollector |
protected Vector |
sb |
protected Vector |
yiRow |
Constructor and Description |
---|
QRReducer() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup(org.apache.hadoop.mapreduce.Reducer.Context context) |
protected void |
reduce(SplitPartitionedWritable key,
Iterable<DenseBlockWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context context) |
protected void |
setup(org.apache.hadoop.mapreduce.Reducer.Context context) |
protected void |
setupBlock(org.apache.hadoop.mapreduce.Reducer.Context context,
SplitPartitionedWritable spw) |
protected int blockHeight
protected int lastTaskId
protected org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,DenseBlockWritable> qhatCollector
protected org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,VectorWritable> rhatCollector
protected QRFirstStep qr
protected Vector yiRow
protected Vector sb
protected void setup(org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Reducer<SplitPartitionedWritable,DenseBlockWritable,SplitPartitionedWritable,VectorWritable>
IOException
InterruptedException
protected void setupBlock(org.apache.hadoop.mapreduce.Reducer.Context context, SplitPartitionedWritable spw) throws InterruptedException, IOException
InterruptedException
IOException
protected void reduce(SplitPartitionedWritable key, Iterable<DenseBlockWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
reduce
in class org.apache.hadoop.mapreduce.Reducer<SplitPartitionedWritable,DenseBlockWritable,SplitPartitionedWritable,VectorWritable>
IOException
InterruptedException
protected void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
cleanup
in class org.apache.hadoop.mapreduce.Reducer<SplitPartitionedWritable,DenseBlockWritable,SplitPartitionedWritable,VectorWritable>
IOException
InterruptedException
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.