Uses of Class
com.hazelcast.mapreduce.impl.notification.MapReduceNotification

Packages that use MapReduceNotification
com.hazelcast.mapreduce.impl This package contains the default implementation for the map reduce framework internals. 
com.hazelcast.mapreduce.impl.notification This package contains all remote node notifications 
com.hazelcast.mapreduce.impl.operation This package contains all remote operations that are needed to control work on supervising or worker nodes. 
com.hazelcast.mapreduce.impl.task This package contains the base implementation for a standard map reduce job. 
 

Uses of MapReduceNotification in com.hazelcast.mapreduce.impl
 

Methods in com.hazelcast.mapreduce.impl with parameters of type MapReduceNotification
 void MapReduceService.dispatchEvent(MapReduceNotification notification)
           
 void MapReduceService.sendNotification(Address address, MapReduceNotification notification)
           
 

Uses of MapReduceNotification in com.hazelcast.mapreduce.impl.notification
 

Subclasses of MapReduceNotification in com.hazelcast.mapreduce.impl.notification
 class IntermediateChunkNotification<KeyOut,Value>
          Notification that is fired every time the chunk limit is reached and is send to the reducers
 class LastChunkNotification<KeyOut,Value>
          This notification is used to notify the reducer that this chunk is the last chunk of the defined partitionId.
 class MemberAwareMapReduceNotification
          Base class for all notifications based on a member
 class ReducingFinishedNotification
          This notification class is used to signal the JobSupervisor owner node that a reducer has finished the reducing step for the defined partitionId.
 

Uses of MapReduceNotification in com.hazelcast.mapreduce.impl.operation
 

Constructors in com.hazelcast.mapreduce.impl.operation with parameters of type MapReduceNotification
FireNotificationOperation(MapReduceNotification notification)
           
 

Uses of MapReduceNotification in com.hazelcast.mapreduce.impl.task
 

Methods in com.hazelcast.mapreduce.impl.task with parameters of type MapReduceNotification
 void JobSupervisor.onNotification(MapReduceNotification notification)
           
 



Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.