public class NettyConnectionManager extends Object implements ConnectionManager
Constructor and Description |
---|
NettyConnectionManager(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() |
void |
start(ResultPartitionProvider partitionProvider,
TaskEventDispatcher taskEventDispatcher,
NetworkBufferPool networkbufferPool) |
public NettyConnectionManager(NettyConfig nettyConfig)
public void start(ResultPartitionProvider partitionProvider, TaskEventDispatcher taskEventDispatcher, NetworkBufferPool networkbufferPool) throws IOException
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–2017 The Apache Software Foundation. All rights reserved.