Package org.apache.hadoop.mapred

Class ShuffleChannelHandler.ReduceContext

java.lang.Object

org.apache.hadoop.mapred.ShuffleChannelHandler.ReduceContext

Enclosing class:

ShuffleChannelHandler

public static class ShuffleChannelHandler.ReduceContext
extends Object

Maintain parameters per messageReceived() Netty context. Allows sendMapOutput calls from operationComplete()

Method Summary

Modifier and Type	Method	Description
io.netty.channel.ChannelHandlerContext	getCtx()
Map<String,org.apache.hadoop.mapred.ShuffleChannelHandler.MapOutputInfo>	getInfoMap()
String	getJobId()
boolean	getKeepAlive()
List<String>	getMapIds()
AtomicInteger	getMapsToSend()
AtomicInteger	getMapsToWait()
int	getReduceId()
String	getUser()

Methods inherited from class java.lang.Object

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

Method Details

getReduceId

public int getReduceId()

getCtx

public io.netty.channel.ChannelHandlerContext getCtx()

getUser

public String getUser()

getInfoMap

public Map<String,org.apache.hadoop.mapred.ShuffleChannelHandler.MapOutputInfo> getInfoMap()

getJobId

public String getJobId()

getMapIds

public List<String> getMapIds()

getMapsToSend

public AtomicInteger getMapsToSend()

getMapsToWait

public AtomicInteger getMapsToWait()

getKeepAlive

public boolean getKeepAlive()