org.apache.flink.runtime.io.network.partition

Interface ResultPartitionConsumableNotifier

All Known Implementing Classes:

RpcResultPartitionConsumableNotifier

public interface ResultPartitionConsumableNotifier

Interface for notifications about consumable partitions.

Method Summary

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

Method Detail

notifyPartitionConsumable

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