org.apache.flink.runtime.taskexecutor.rpc

Class RpcResultPartitionConsumableNotifier

java.lang.Object

org.apache.flink.runtime.taskexecutor.rpc.RpcResultPartitionConsumableNotifier

All Implemented Interfaces:

ResultPartitionConsumableNotifier

public class RpcResultPartitionConsumableNotifier
extends Object
implements ResultPartitionConsumableNotifier

Constructor Summary

Constructors

Constructor and Description
RpcResultPartitionConsumableNotifier(JobMasterGateway jobMasterGateway, Executor executor, Time timeout)

Method Summary

Modifier and Type	Method and Description
void	notifyPartitionConsumable(JobID jobId, ResultPartitionID partitionId, TaskActions taskActions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RpcResultPartitionConsumableNotifier

public RpcResultPartitionConsumableNotifier(JobMasterGateway jobMasterGateway,
                                            Executor executor,
                                            Time timeout)

Method Detail

notifyPartitionConsumable

public void notifyPartitionConsumable(JobID jobId,
                                      ResultPartitionID partitionId,
                                      TaskActions taskActions)

Specified by:

notifyPartitionConsumable in interface ResultPartitionConsumableNotifier