Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.netty |
Modifier and Type | Method and Description |
---|---|
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 |
NetworkClientHandler.notifyCreditAvailable(RemoteInputChannel inputChannel)
The credit begins to announce after receiving the sender's backlog from buffer response.
|
void |
PartitionRequestClient.notifyCreditAvailable(RemoteInputChannel inputChannel)
Notifies available credits 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.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.close(RemoteInputChannel inputChannel) |
void |
NettyPartitionRequestClient.notifyCreditAvailable(RemoteInputChannel inputChannel) |
void |
NettyPartitionRequestClient.requestSubpartition(ResultPartitionID partitionId,
int subpartitionIndex,
RemoteInputChannel inputChannel,
int delayMs)
Requests a remote intermediate result partition queue.
|
void |
NettyPartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId,
TaskEvent event,
RemoteInputChannel inputChannel)
Sends a task event backwards to an intermediate result partition producer.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.