org.apache.flink.runtime.taskmanager

Class ConsumableNotifyingResultPartitionWriterDecorator

java.lang.Object

org.apache.flink.runtime.taskmanager.ConsumableNotifyingResultPartitionWriterDecorator

public class ConsumableNotifyingResultPartitionWriterDecorator
extends Object

A utility to wrap a ResultPartitionWriter for that sends a "consumable" notification on the first record.

Note: This is only needed for lazy batch scheduling and thus an artifact that can be removed once we drop lazy-from-sources scheduling.

Method Summary

Modifier and Type

Method and Description

static ResultPartitionWriter[]

decorate(Collection<ResultPartitionDeploymentDescriptor> descs, ResultPartitionWriter[] partitionWriters, TaskActions taskActions, JobID jobId, ResultPartitionConsumableNotifier notifier) Optionally decorate the ResultPartitionWriter to call ResultPartitionConsumableNotifier.notifyPartitionConsumable(JobID, ResultPartitionID, TaskActions) on the first record, iff ResultPartitionDeploymentDescriptor.sendScheduleOrUpdateConsumersMessage() is true.

Methods inherited from class java.lang.Object

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

Method Detail

decorate

public static ResultPartitionWriter[] decorate(Collection<ResultPartitionDeploymentDescriptor> descs,
                                               ResultPartitionWriter[] partitionWriters,
                                               TaskActions taskActions,
                                               JobID jobId,
                                               ResultPartitionConsumableNotifier notifier)

Optionally decorate the ResultPartitionWriter to call ResultPartitionConsumableNotifier.notifyPartitionConsumable(JobID, ResultPartitionID, TaskActions) on the first record, iff ResultPartitionDeploymentDescriptor.sendScheduleOrUpdateConsumersMessage() is true.