public class ConnectionID extends Object implements Serializable
ConnectionID
identifies a connection to a remote task manager by the socket address and
a connection index. This allows multiple connections to the same task manager to be distinguished
by their connection index.
The connection index is assigned by the IntermediateResult
and ensures that it is
safe to multiplex multiple data transfers over the same physical TCP connection.
Constructor and Description |
---|
ConnectionID(InetSocketAddress address,
int connectionIndex) |
ConnectionID(TaskManagerLocation connectionInfo,
int connectionIndex) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object other) |
InetSocketAddress |
getAddress() |
int |
getConnectionIndex() |
int |
hashCode() |
String |
toString() |
public ConnectionID(TaskManagerLocation connectionInfo, int connectionIndex)
public ConnectionID(InetSocketAddress address, int connectionIndex)
public InetSocketAddress getAddress()
public int getConnectionIndex()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.