Modifier and Type | Method and Description |
---|---|
void |
ConnectionManager.closeOpenChannelConnections(ConnectionID connectionId)
Closes opened ChannelConnections in case of a resource release.
|
void |
LocalConnectionManager.closeOpenChannelConnections(ConnectionID connectionId) |
PartitionRequestClient |
ConnectionManager.createPartitionRequestClient(ConnectionID connectionId)
Creates a
PartitionRequestClient instance for the given ConnectionID . |
PartitionRequestClient |
LocalConnectionManager.createPartitionRequestClient(ConnectionID 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,
InputChannelMetrics metrics,
MemorySegmentProvider memorySegmentProvider) |
Modifier and Type | Method and Description |
---|---|
ConnectionID |
NettyShuffleDescriptor.getConnectionId() |
ConnectionID |
NettyShuffleDescriptor.PartitionConnectionInfo.getConnectionId() |
ConnectionID |
NettyShuffleDescriptor.NetworkPartitionConnectionInfo.getConnectionId() |
ConnectionID |
NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo.getConnectionId() |
Constructor and Description |
---|
NetworkPartitionConnectionInfo(ConnectionID connectionID) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.