public class InputHost extends Object
Constructor and Description |
---|
InputHost(String hostName,
int port,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
int srcPhysicalIndex) |
Modifier and Type | Method and Description |
---|---|
void |
addKnownInput(InputAttemptIdentifier srcAttempt) |
List<InputAttemptIdentifier> |
clearAndGetPendingInputs() |
static String |
createIdentifier(String host,
int port) |
boolean |
equals(Object obj) |
String |
getAdditionalInfo() |
String |
getHost() |
String |
getIdentifier() |
int |
getNumPendingInputs() |
int |
getPort() |
int |
getSrcPhysicalIndex() |
int |
hashCode() |
void |
setAdditionalInfo(String additionalInfo) |
String |
toDetailedString() |
String |
toString() |
public InputHost(String hostName, int port, org.apache.hadoop.yarn.api.records.ApplicationId appId, int srcPhysicalIndex)
public String getHost()
public int getPort()
public String getIdentifier()
public void setAdditionalInfo(String additionalInfo)
public String getAdditionalInfo()
public int getSrcPhysicalIndex()
public int getNumPendingInputs()
public void addKnownInput(InputAttemptIdentifier srcAttempt)
public List<InputAttemptIdentifier> clearAndGetPendingInputs()
public String toDetailedString()
Copyright © 2016 Apache Software Foundation. All rights reserved.