public abstract class PipeMapRed
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
protected java.lang.Throwable |
outerrThreadsThrowable |
Constructor and Description |
---|
PipeMapRed() |
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf job) |
java.io.DataInput |
getClientInput()
Returns the DataInput from which the client output is read.
|
java.io.DataOutput |
getClientOutput()
Returns the DataOutput to which the client input is written.
|
org.apache.hadoop.conf.Configuration |
getConfiguration()
Returns the Configuration.
|
java.lang.String |
getContext() |
abstract byte[] |
getFieldSeparator()
Returns the field separator to be used.
|
abstract byte[] |
getInputSeparator()
Returns the input separator to be used.
|
abstract int |
getNumOfKeyFields()
Returns the number of key fields.
|
void |
mapRedFinished() |
protected static final org.apache.commons.logging.Log LOG
protected volatile java.lang.Throwable outerrThreadsThrowable
public org.apache.hadoop.conf.Configuration getConfiguration()
public java.io.DataOutput getClientOutput()
public java.io.DataInput getClientInput()
public abstract byte[] getInputSeparator()
public abstract byte[] getFieldSeparator()
public abstract int getNumOfKeyFields()
public void configure(JobConf job)
public void mapRedFinished()
public java.lang.String getContext()
Copyright © 2009 The Apache Software Foundation