Uses of Package
com.hazelcast.mapreduce

Packages that use com.hazelcast.mapreduce

com.hazelcast.client	This package contains the serverside client functionality
com.hazelcast.config	Provides classes for configuring HazelcastInstance.
com.hazelcast.core	Provides core API interfaces/classes.
com.hazelcast.mapreduce	This package contains the MapReduce API definition for Hazelcast. All map reduce operations running in a distributed manner inside the active Hazelcast cluster.

Classes in com.hazelcast.mapreduce used by com.hazelcast.client

JobTracker
The JobTracker interface is used to create instances of Jobs depending on the given data structure / data source.

Classes in com.hazelcast.mapreduce used by com.hazelcast.config

TopologyChangedStrategy
This enum class is used to define how a map reduce job behaves if the job owner recognizes a topology changed event.
When members are leaving the cluster it might happen to loose processed data chunks that were already send to the reducers on the leaving node.
In addition to that on any topology change there is a redistribution of the member assigned partitions which means that a map job might have a problem to finish it's currently processed partition.
The default behavior is immediately cancelling the running task and throwing an TopologyChangedException but it is possible to submit the same job configuration again if JobTracker.getTrackableJob(String) returns null for the requested job id.

Classes in com.hazelcast.mapreduce used by com.hazelcast.core

JobTracker
The JobTracker interface is used to create instances of Jobs depending on the given data structure / data source.

Classes in com.hazelcast.mapreduce used by com.hazelcast.mapreduce

Collator
This interface can be implemented to define a Collator which is executed after calculation of the MapReduce algorithm on remote cluster nodes but before returning the final result.
Collator can for example be used to sum up a final value.

Combiner
The abstract Combiner class is used to build combiners for the Job.
Those Combiners are distributed inside of the cluster and are running alongside the Mapper implementations in the same node.
Combiners are called in a threadsafe way so internal locking is not required.

CombinerFactory
A CombinerFactory implementation is used to build Combiner instances per key.
An implementation needs to be serializable by Hazelcast since it is distributed together with the Mapper implementation to run alongside.

Context
The Context interface is used for emitting keys and values to the sample space of the MapReduce algorithm.

Job
This interface describes a mapreduce Job that is build by JobTracker.newJob(KeyValueSource).
It is used to execute mappings and calculations on the different cluster nodes and reduce or collate these mapped values to results.

JobCompletableFuture
This is a special version of ICompletableFuture to return the assigned job id of the submit operation.

JobPartitionState
An implementation of this interface contains current information about the status of an process piece while operation is executing.

JobPartitionState.State
Definition of the processing states

JobProcessInformation
This interface holds basic information about a running map reduce job like state of the different partitions and the number of currently processed records.
The number of processed records is not a real time value but updated on regular base (after 1000 processed elements per node).

JobTracker
The JobTracker interface is used to create instances of Jobs depending on the given data structure / data source.

KeyPredicate
This interface is used to pre evaluate keys before spreading the MapReduce task to the cluster.

KeyValueSource
The abstract KeyValueSource class is used to implement custom data sources for mapreduce algorithms.
Default shipped implementations contains KeyValueSources for Hazelcast data structures like IMap and MultiMap.

LifecycleMapper
The LifecycleMapper interface is a more sophisticated version of Mapper normally used for complexer algorithms with a need of initialization and finalization.

Mapper
The interface Mapper is used to build mappers for the Job.

MappingJob
This interface describes a mapping mapreduce Job.
For further information Job.

Reducer
The abstract Reducer class is used to build reducers for the Job.
Reducers may be distributed inside of the cluster but there is always only one Reducer per key.
Reducers are called in a threadsafe way so internal locking is not required.

ReducerFactory
A ReducerFactory implementation is used to build Reducer instances per key.
An implementation needs to be serializable by Hazelcast since it might be distributed inside the cluster to do parallel calculations of reducing step.

ReducingJob
This interface describes a reducing mapreduce Job.
For further information Job.

ReducingSubmittableJob
This interface describes a submittable mapreduce Job.
For further information Job.

TopologyChangedStrategy
This enum class is used to define how a map reduce job behaves if the job owner recognizes a topology changed event.
When members are leaving the cluster it might happen to loose processed data chunks that were already send to the reducers on the leaving node.
In addition to that on any topology change there is a redistribution of the member assigned partitions which means that a map job might have a problem to finish it's currently processed partition.
The default behavior is immediately cancelling the running task and throwing an TopologyChangedException but it is possible to submit the same job configuration again if JobTracker.getTrackableJob(String) returns null for the requested job id.

TrackableJob
This interface describes a trackable job.