|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.streaming.PipeMapRed
public abstract class PipeMapRed
Shared functionality for PipeMapper, PipeReducer.
Field Summary | |
---|---|
protected static org.apache.commons.logging.Log |
LOG
|
protected Throwable |
outerrThreadsThrowable
|
Constructor Summary | |
---|---|
PipeMapRed()
|
Method Summary | |
---|---|
void |
configure(JobConf job)
|
DataInput |
getClientInput()
Returns the DataInput from which the client output is read. |
DataOutput |
getClientOutput()
Returns the DataOutput to which the client input is written. |
Configuration |
getConfiguration()
Returns the Configuration. |
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()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final org.apache.commons.logging.Log LOG
protected volatile Throwable outerrThreadsThrowable
Constructor Detail |
---|
public PipeMapRed()
Method Detail |
---|
public Configuration getConfiguration()
public DataOutput getClientOutput()
public DataInput getClientInput()
public abstract byte[] getInputSeparator()
public abstract byte[] getFieldSeparator()
public abstract int getNumOfKeyFields()
public void configure(JobConf job)
public void mapRedFinished()
public String getContext()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |