edu.stolaf.cs.wmrserver.streaming
Class PipeMapRed

java.lang.Object
  edu.stolaf.cs.wmrserver.streaming.PipeMapRed

Direct Known Subclasses:

PipeMapper, PipeReducer

public abstract class PipeMapRed
extends java.lang.Object

Shared functionality for PipeMapper, PipeReducer.

Field Summary

protected static org.apache.commons.logging.Log	LOG
protected java.lang.Throwable	outerrThreadsThrowable

Constructor Summary

PipeMapRed()

Method Summary

void	configure(org.apache.hadoop.mapred.JobConf job)
java.lang.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 java.lang.Throwable outerrThreadsThrowable

Constructor Detail

PipeMapRed

public PipeMapRed()

Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

mapRedFinished

public void mapRedFinished()

getContext

public java.lang.String getContext()