public interface NetworkClientHandler
extends org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler
Modifier and Type | Method and Description |
---|---|
void |
addInputChannel(RemoteInputChannel inputChannel) |
void |
cancelRequestFor(InputChannelID inputChannelId) |
RemoteInputChannel |
getInputChannel(InputChannelID inputChannelId) |
boolean |
hasChannelError()
Return whether there is channel error.
|
void |
removeInputChannel(RemoteInputChannel inputChannel) |
void |
setConnectionId(ConnectionID connectionId) |
void addInputChannel(RemoteInputChannel inputChannel) throws IOException
IOException
void removeInputChannel(RemoteInputChannel inputChannel)
@Nullable RemoteInputChannel getInputChannel(InputChannelID inputChannelId)
void cancelRequestFor(InputChannelID inputChannelId)
void setConnectionId(ConnectionID connectionId)
boolean hasChannelError()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.