org.apache.hadoop.mapreduce.task.reduce
Class MapHost

java.lang.Object
  extended by org.apache.hadoop.mapreduce.task.reduce.MapHost

@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public class MapHost
extends Object


Nested Class Summary
static class MapHost.State
           
 
Constructor Summary
MapHost(String hostName, String baseUrl)
           
 
Method Summary
 void addKnownMap(TaskAttemptID mapId)
           
 List<TaskAttemptID> getAndClearKnownMaps()
           
 String getBaseUrl()
           
 String getHostName()
           
 int getNumKnownMapOutputs()
           
 MapHost.State getState()
           
 MapHost.State markAvailable()
          Called when the node is done with its penalty or done copying.
 void markBusy()
           
 void markPenalized()
           
 void penalize()
          Mark the host as penalized
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MapHost

public MapHost(String hostName,
               String baseUrl)
Method Detail

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.