This operation is fired by the jobs owner node to remotely cancel the defined jobId on all nodes.
This operation is used to transport and execute a notification on a remote node since the current event service is not capable of reliable transmission so this is a fallback to sync operations which is hopefully only a temporary workaround!
This operation is used to retrieve results from a remote node
This class is used to create
In difference to other implementations of
This operation is used to request assignment for keys on the job owners node.
This class is used to store assignment results in
This operation is used to prepare a
This operation is used to inform the job owner of a remote exception
This operation is used to tell the job owner to postpone a mapping phase for the defined partitionId.
This is the base class for all map reduce framework operations, it always contains the name of the JobTracker and the unique jobId
This operation is used to update the process statistics on the owner node
This operation is used to do some kind of partitionId based processing on non partition based implementations of
This operation requests a new partition to process by the requester on the job owning node
This operation tells the job owner to mark a partition as fully processed
This operation tells the job owner to start reducing phase of the defined partition on the first occurrence of a full emitted chunk
This class is used to store the requested result of all kinds of processing operations.
By default it holds a basic result state and maybe the partitionId it was operated otherwise it's value is defined as -1
This operation is used to start the actual processing after all node prepared to execute the map reduce job
This enum is used to define the basic state of an operations result
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.