org.apache.hadoop.streaming

类 PipeMapRed

java.lang.Object

org.apache.hadoop.streaming.PipeMapRed

直接已知子类:

PipeMapper, PipeReducer

public abstract class PipeMapRed
extends Object

Shared functionality for PipeMapper, PipeReducer.

字段概要

字段

限定符和类型	字段和说明
protected static org.apache.commons.logging.Log	LOG
protected Throwable	outerrThreadsThrowable

构造器概要

构造器

构造器和说明
PipeMapRed()

方法概要

方法

限定符和类型	方法和说明
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()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

LOG

protected static final org.apache.commons.logging.Log LOG

outerrThreadsThrowable

protected volatile Throwable outerrThreadsThrowable

构造器详细资料

PipeMapRed

public PipeMapRed()

方法详细资料

getConfiguration

public Configuration getConfiguration()

Returns the Configuration.

getClientOutput

public DataOutput getClientOutput()

Returns the DataOutput to which the client input is written.

getClientInput

public DataInput getClientInput()

Returns the DataInput from which the client output is read.

getInputSeparator

public abstract byte[] getInputSeparator()

Returns the input separator to be used.

getFieldSeparator

public abstract byte[] getFieldSeparator()

Returns the field separator to be used.

getNumOfKeyFields

public abstract int getNumOfKeyFields()

Returns the number of key fields.

configure

public void configure(JobConf job)

mapRedFinished

public void mapRedFinished()

getContext

public String getContext()