private void notifyPipelinedConsumers ( ) { if ( sendScheduleOrUpdateConsumersMessage && ! hasNotifiedPipelinedConsumers && partitionType . isPipelined ( ) ) { partitionConsumableNotifier . notifyPartitionConsumable ( jobId , partitionId , taskActions ) ; hasNotifiedPipelinedConsumers = true ; } }
Notifies pipelined consumers of this result partition once .