org.apache.flink.runtime.taskmanager

Class ActorGatewayResultPartitionConsumableNotifier

java.lang.Object

org.apache.flink.runtime.taskmanager.ActorGatewayResultPartitionConsumableNotifier

All Implemented Interfaces:

ResultPartitionConsumableNotifier

public class ActorGatewayResultPartitionConsumableNotifier
extends Object
implements ResultPartitionConsumableNotifier

This implementation uses ActorGateway to notify the job manager about consumable partitions.

Constructor Summary

Constructors

Constructor and Description
ActorGatewayResultPartitionConsumableNotifier(scala.concurrent.ExecutionContext executionContext, ActorGateway jobManager, scala.concurrent.duration.FiniteDuration jobManagerMessageTimeout)

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

ActorGatewayResultPartitionConsumableNotifier

public ActorGatewayResultPartitionConsumableNotifier(scala.concurrent.ExecutionContext executionContext,
                                                     ActorGateway jobManager,
                                                     scala.concurrent.duration.FiniteDuration jobManagerMessageTimeout)

Method Detail

notifyPartitionConsumable

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

Specified by:

notifyPartitionConsumable in interface ResultPartitionConsumableNotifier