org.apache.hadoop.streaming
Class PipeMapRed

java.lang.Object
  org.apache.hadoop.streaming.PipeMapRed

Direct Known Subclasses:

PipeMapper, PipeReducer

public abstract class PipeMapRed
extends Object

Shared functionality for PipeMapper, PipeReducer.

Field Summary

protected static org.apache.commons.logging.Log	LOG
protected char	mapOutputFieldSeparator
protected int	numOfMapOutputKeyFields
protected int	numOfMapOutputPartitionFields
protected int	numOfReduceOutputKeyFields
protected Throwable	outerrThreadsThrowable
protected char	reduceOutFieldSeparator

Constructor Summary

PipeMapRed()

Method Summary

void	configure(JobConf job)
String	getContext()
void	mapRedFinished()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

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

outerrThreadsThrowable

protected volatile Throwable outerrThreadsThrowable

mapOutputFieldSeparator

protected char mapOutputFieldSeparator

reduceOutFieldSeparator

protected char reduceOutFieldSeparator

numOfMapOutputKeyFields

protected int numOfMapOutputKeyFields

numOfMapOutputPartitionFields

protected int numOfMapOutputPartitionFields

numOfReduceOutputKeyFields

protected int numOfReduceOutputKeyFields

Constructor Detail

PipeMapRed

public PipeMapRed()

Method Detail

configure

public void configure(JobConf job)

mapRedFinished

public void mapRedFinished()

getContext

public String getContext()