public interface ConnectionManager
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 |
getDataPort() |
int |
getNumberOfActiveConnections() |
void |
shutdown() |
void |
start(ResultPartitionProvider partitionProvider,
TaskEventDispatcher taskEventDispatcher,
NetworkBufferPool networkbufferPool) |
void start(ResultPartitionProvider partitionProvider, TaskEventDispatcher taskEventDispatcher, NetworkBufferPool networkbufferPool) throws IOException
IOException
PartitionRequestClient createPartitionRequestClient(ConnectionID connectionId) throws IOException, InterruptedException
PartitionRequestClient
instance for the given ConnectionID
.IOException
InterruptedException
void closeOpenChannelConnections(ConnectionID connectionId)
int getNumberOfActiveConnections()
int getDataPort()
void shutdown() throws IOException
IOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.