org.apache.tez.runtime.library.shuffle.common
Class InputHost

java.lang.Object
  org.apache.tez.runtime.library.shuffle.common.InputHost

public class InputHost
extends Object

Represents a Host with respect to the MapReduce ShuffleHandler. srcPhysicalIndex / partition is part of this since that only knows how to serve ine partition at a time.

Constructor Summary

InputHost(String hostName, int port, org.apache.hadoop.yarn.api.records.ApplicationId appId, int srcPhysicalIndex)

Method Summary

void	addKnownInput(InputAttemptIdentifier srcAttempt)
List<InputAttemptIdentifier>	clearAndGetPendingInputs()
boolean	equals(Object obj)
String	getHost()
int	getNumPendingInputs()
int	getPort()
int	getSrcPhysicalIndex()
int	hashCode()
String	toDetailedString()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

InputHost

public InputHost(String hostName,
                 int port,
                 org.apache.hadoop.yarn.api.records.ApplicationId appId,
                 int srcPhysicalIndex)

Method Detail

getHost

public String getHost()

getPort

public int getPort()

getSrcPhysicalIndex

public int getSrcPhysicalIndex()

getNumPendingInputs

public int getNumPendingInputs()

addKnownInput

public void addKnownInput(InputAttemptIdentifier srcAttempt)

clearAndGetPendingInputs

public List<InputAttemptIdentifier> clearAndGetPendingInputs()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toDetailedString

public String toDetailedString()

toString

public String toString()

Overrides:

toString in class Object