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) |
Modifier and Type | Method and Description |
---|---|
RemoteInputChannel |
UnknownInputChannel.toRemoteInputChannel(ConnectionID producerAddress) |
Constructor and Description |
---|
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
IOMetricGroup metrics) |
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
scala.Tuple2<Integer,Integer> initialAndMaxBackoff,
IOMetricGroup metrics) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.