Uses of Class
org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel

Packages that use RemoteInputChannel

Package	Description
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.netty

Uses of RemoteInputChannel in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network with parameters of type RemoteInputChannel

Modifier and Type	Method and Description
void	NetworkClientHandler.addInputChannel(RemoteInputChannel inputChannel)
void	NetworkClientHandler.notifyCreditAvailable(RemoteInputChannel inputChannel) The credit begins to announce after receiving the sender's backlog from buffer response.
void	NetworkClientHandler.removeInputChannel(RemoteInputChannel inputChannel)

Uses of RemoteInputChannel in org.apache.flink.runtime.io.network.netty

Methods in org.apache.flink.runtime.io.network.netty with parameters of type RemoteInputChannel

Modifier and Type	Method and Description
void	PartitionRequestClient.close(RemoteInputChannel inputChannel)
void	PartitionRequestClient.notifyCreditAvailable(RemoteInputChannel inputChannel)
org.apache.flink.shaded.netty4.io.netty.channel.ChannelFuture	PartitionRequestClient.requestSubpartition(ResultPartitionID partitionId, int subpartitionIndex, RemoteInputChannel inputChannel, int delayMs) Requests a remote intermediate result partition queue.
void	PartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId, TaskEvent event, RemoteInputChannel inputChannel) Sends a task event backwards to an intermediate result partition producer.