public class PartitionRequestClient extends Object
This client is shared by all remote input channels, which request a partition
from the same ConnectionID
.
Modifier and Type | Method and Description |
---|---|
void |
close(RemoteInputChannel inputChannel) |
void |
notifyCreditAvailable(RemoteInputChannel inputChannel) |
org.apache.flink.shaded.netty4.io.netty.channel.ChannelFuture |
requestSubpartition(ResultPartitionID partitionId,
int subpartitionIndex,
RemoteInputChannel inputChannel,
int delayMs)
Requests a remote intermediate result partition queue.
|
void |
sendTaskEvent(ResultPartitionID partitionId,
TaskEvent event,
RemoteInputChannel inputChannel)
Sends a task event backwards to an intermediate result partition producer.
|
public org.apache.flink.shaded.netty4.io.netty.channel.ChannelFuture requestSubpartition(ResultPartitionID partitionId, int subpartitionIndex, RemoteInputChannel inputChannel, int delayMs) throws IOException
The request goes to the remote producer, for which this partition request client instance has been created.
IOException
public void sendTaskEvent(ResultPartitionID partitionId, TaskEvent event, RemoteInputChannel inputChannel) throws IOException
Backwards task events flow between readers and writers and therefore will only work when both are running at the same time, which is only guaranteed to be the case when both the respective producer and consumer task run pipelined.
IOException
public void notifyCreditAvailable(RemoteInputChannel inputChannel)
public void close(RemoteInputChannel inputChannel) throws IOException
IOException
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.