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 |
getHost() |
String |
getIdentifier() |
int |
getNumPendingInputs() |
int |
getPort() |
int |
getSrcPhysicalIndex() |
int |
hashCode() |
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 int getSrcPhysicalIndex()
public int getNumPendingInputs()
public void addKnownInput(InputAttemptIdentifier srcAttempt)
public List<InputAttemptIdentifier> clearAndGetPendingInputs()
public String toDetailedString()
Copyright © 2015 Apache Software Foundation. All rights reserved.