Modifier and Type | Method and Description |
---|---|
ConnectionID |
ResultPartitionLocation.getConnectionId() |
Modifier and Type | Method and Description |
---|---|
static ResultPartitionLocation |
ResultPartitionLocation.createRemote(ConnectionID connectionId) |
Modifier and Type | Method and Description |
---|---|
void |
LocalConnectionManager.closeOpenChannelConnections(ConnectionID connectionId) |
void |
ConnectionManager.closeOpenChannelConnections(ConnectionID connectionId)
Closes opened ChannelConnections in case of a resource release
|
PartitionRequestClient |
LocalConnectionManager.createPartitionRequestClient(ConnectionID connectionId) |
PartitionRequestClient |
ConnectionManager.createPartitionRequestClient(ConnectionID connectionId)
Creates a
PartitionRequestClient instance for the given ConnectionID . |
Modifier and Type | Method and Description |
---|---|
void |
NettyConnectionManager.closeOpenChannelConnections(ConnectionID connectionId) |
PartitionRequestClient |
NettyConnectionManager.createPartitionRequestClient(ConnectionID connectionId) |
Constructor and Description |
---|
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
int initialBackOff,
int maxBackoff,
TaskIOMetricGroup metrics) |
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
TaskIOMetricGroup metrics) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.