public interface PartitionRequestClient
RemoteInputChannel
.Modifier and Type | Method and Description |
---|---|
void |
close(RemoteInputChannel inputChannel)
Cancels the partition request for the given remote input channel and removes this client from
factory if it is not referenced by any other input channels.
|
void |
notifyCreditAvailable(RemoteInputChannel inputChannel)
Notifies available credits from one remote input channel.
|
void |
requestSubpartition(ResultPartitionID partitionId,
int subpartitionIndex,
RemoteInputChannel inputChannel,
int delayMs)
Requests a remote sub partition.
|
void |
resumeConsumption(RemoteInputChannel inputChannel)
Requests to resume data consumption from one remote input channel.
|
void |
sendTaskEvent(ResultPartitionID partitionId,
TaskEvent event,
RemoteInputChannel inputChannel)
Sends a task event backwards to an intermediate result partition.
|
void requestSubpartition(ResultPartitionID partitionId, int subpartitionIndex, RemoteInputChannel inputChannel, int delayMs) throws IOException
partitionId
- The identifier of result partition to be requested.subpartitionIndex
- The sub partition index in the requested result partition.inputChannel
- The remote input channel for requesting the sub partition.delayMs
- The request is scheduled within a delay time.IOException
void notifyCreditAvailable(RemoteInputChannel inputChannel)
inputChannel
- The remote input channel who announces the available credits.void resumeConsumption(RemoteInputChannel inputChannel)
inputChannel
- The remote input channel who is ready to resume data consumption.void sendTaskEvent(ResultPartitionID partitionId, TaskEvent event, RemoteInputChannel inputChannel) throws IOException
partitionId
- The identifier of result partition.event
- The task event to be sent.inputChannel
- The remote input channel for sending this event.IOException
void close(RemoteInputChannel inputChannel) throws IOException
inputChannel
- The remote input channel for canceling partition and to be removed from
network stack.IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.