public class QRFirstStep extends Object implements Closeable, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,Vector>
Modifier and Type | Field and Description |
---|---|
static String |
PROP_AROWBLOCK_SIZE |
static String |
PROP_K |
static String |
PROP_P |
Constructor and Description |
---|
QRFirstStep(org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.mapred.OutputCollector<? super org.apache.hadoop.io.Writable,? super DenseBlockWritable> qtHatOut,
org.apache.hadoop.mapred.OutputCollector<? super org.apache.hadoop.io.Writable,? super VectorWritable> rHatOut) |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup() |
void |
close() |
void |
collect(org.apache.hadoop.io.Writable key,
Vector vw) |
int |
getKP() |
protected void |
map(Vector incomingYRow) |
protected void |
setup() |
public static final String PROP_K
public static final String PROP_P
public static final String PROP_AROWBLOCK_SIZE
public QRFirstStep(org.apache.hadoop.conf.Configuration jobConf, org.apache.hadoop.mapred.OutputCollector<? super org.apache.hadoop.io.Writable,? super DenseBlockWritable> qtHatOut, org.apache.hadoop.mapred.OutputCollector<? super org.apache.hadoop.io.Writable,? super VectorWritable> rHatOut)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public int getKP()
protected void map(Vector incomingYRow) throws IOException
IOException
protected void setup()
protected void cleanup() throws IOException
IOException
public void collect(org.apache.hadoop.io.Writable key, Vector vw) throws IOException
collect
in interface org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Writable,Vector>
IOException
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.