See: Description
Class | Description |
---|---|
IntermediateChunkNotification<KeyOut,Value> |
Notification that is fired every time the chunk limit is reached and is send to the reducers
|
LastChunkNotification<KeyOut,Value> |
This notification is used to notify the reducer that this chunk is the last chunk of the
defined partitionId.
|
MapReduceNotification |
Base class for all map reduce framework notifications
|
MemberAwareMapReduceNotification |
Base class for all notifications based on a member
|
ReducingFinishedNotification |
This notification class is used to signal the
JobSupervisor
owner node that a reducer has finished the reducing step for the defined partitionId. |
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.