public class NettyConnectionManager extends Object implements ConnectionManager
Constructor and Description |
---|
NettyConnectionManager(ResultPartitionProvider partitionProvider,
TaskEventPublisher taskEventPublisher,
NettyConfig nettyConfig) |
Modifier and Type | Method and Description |
---|---|
void |
closeOpenChannelConnections(ConnectionID connectionId)
Closes opened ChannelConnections in case of a resource release.
|
PartitionRequestClient |
createPartitionRequestClient(ConnectionID connectionId)
Creates a
PartitionRequestClient instance for the given ConnectionID . |
int |
getNumberOfActiveConnections() |
void |
shutdown() |
int |
start()
Starts the internal related components for network connection and communication.
|
public NettyConnectionManager(ResultPartitionProvider partitionProvider, TaskEventPublisher taskEventPublisher, NettyConfig nettyConfig)
public int start() throws IOException
ConnectionManager
start
in interface ConnectionManager
IOException
public PartitionRequestClient createPartitionRequestClient(ConnectionID connectionId) throws IOException, InterruptedException
ConnectionManager
PartitionRequestClient
instance for the given ConnectionID
.createPartitionRequestClient
in interface ConnectionManager
IOException
InterruptedException
public void closeOpenChannelConnections(ConnectionID connectionId)
ConnectionManager
closeOpenChannelConnections
in interface ConnectionManager
public int getNumberOfActiveConnections()
getNumberOfActiveConnections
in interface ConnectionManager
public void shutdown()
shutdown
in interface ConnectionManager
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.