org.apache.hadoop.mapreduce.task.reduce
Class MapHost
java.lang.Object
org.apache.hadoop.mapreduce.task.reduce.MapHost
@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public class MapHost
- extends Object
MapHost
public MapHost(String hostName,
String baseUrl)
getState
public MapHost.State getState()
getHostName
public String getHostName()
getBaseUrl
public String getBaseUrl()
addKnownMap
public void addKnownMap(TaskAttemptID mapId)
getAndClearKnownMaps
public List<TaskAttemptID> getAndClearKnownMaps()
markBusy
public void markBusy()
markPenalized
public void markPenalized()
getNumKnownMapOutputs
public int getNumKnownMapOutputs()
markAvailable
public MapHost.State markAvailable()
- Called when the node is done with its penalty or done copying.
- Returns:
- the host's new state
toString
public String toString()
- Overrides:
toString
in class Object
penalize
public void penalize()
- Mark the host as penalized
Copyright © 2014 Apache Software Foundation. All Rights Reserved.