Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.netty |
Modifier and Type | Method and Description |
---|---|
RemoteInputChannel |
NetworkClientHandler.getInputChannel(InputChannelID inputChannelId) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionRequestClient.acknowledgeAllRecordsProcessed(RemoteInputChannel inputChannel)
Acknowledges all user records are processed for this channel.
|
void |
NetworkClientHandler.addInputChannel(RemoteInputChannel inputChannel) |
void |
PartitionRequestClient.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 |
PartitionRequestClient.notifyCreditAvailable(RemoteInputChannel inputChannel)
Notifies available credits from one remote input channel.
|
void |
PartitionRequestClient.notifyNewBufferSize(RemoteInputChannel inputChannel,
int bufferSize)
Notifies new buffer size from one remote input channel.
|
void |
NetworkClientHandler.removeInputChannel(RemoteInputChannel inputChannel) |
void |
PartitionRequestClient.requestSubpartition(ResultPartitionID partitionId,
int subpartitionIndex,
RemoteInputChannel inputChannel,
int delayMs)
Requests a remote sub partition.
|
void |
PartitionRequestClient.resumeConsumption(RemoteInputChannel inputChannel)
Requests to resume data consumption from one remote input channel.
|
void |
PartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId,
TaskEvent event,
RemoteInputChannel inputChannel)
Sends a task event backwards to an intermediate result partition.
|
Modifier and Type | Method and Description |
---|---|
void |
NettyPartitionRequestClient.acknowledgeAllRecordsProcessed(RemoteInputChannel inputChannel) |
void |
NettyPartitionRequestClient.close(RemoteInputChannel inputChannel) |
void |
NettyPartitionRequestClient.notifyCreditAvailable(RemoteInputChannel inputChannel) |
void |
NettyPartitionRequestClient.notifyNewBufferSize(RemoteInputChannel inputChannel,
int bufferSize) |
void |
NettyPartitionRequestClient.requestSubpartition(ResultPartitionID partitionId,
int subpartitionIndex,
RemoteInputChannel inputChannel,
int delayMs)
Requests a remote intermediate result partition queue.
|
void |
NettyPartitionRequestClient.resumeConsumption(RemoteInputChannel inputChannel) |
void |
NettyPartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId,
TaskEvent event,
RemoteInputChannel inputChannel)
Sends a task event backwards to an intermediate result partition producer.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.