| Package | Description | 
|---|---|
| com.hazelcast.client.proxy | 
 This package contains client side proxy implementations of the different Hazelcast data structures
 and operation types 
 | 
| 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.  | 
| com.hazelcast.mapreduce.impl | 
 This package contains the default implementation for the map reduce framework
 internals. 
 | 
| com.hazelcast.mapreduce.impl.task | 
 This package contains the base implementation for a standard map reduce job. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<K,V> Job<K,V> | 
ClientMapReduceProxy.newJob(KeyValueSource<K,V> source)  | 
| Modifier and Type | Method and Description | 
|---|---|
Job<KeyIn,ValueIn> | 
Job.chunkSize(int chunkSize)
Deprecated.  
Defines the number of elements per chunk. 
 | 
Job<KeyIn,ValueIn> | 
Job.keyPredicate(KeyPredicate<? super KeyIn> predicate)
Deprecated.  
Defines the  
KeyPredicate implementation to preselect keys the MapReduce task will be executed on. | 
<K,V> Job<K,V> | 
JobTracker.newJob(KeyValueSource<K,V> source)
Deprecated.  
Builds a  
Job instance for the given KeyValueSource instance. | 
Job<KeyIn,ValueIn> | 
Job.onKeys(Iterable<? extends KeyIn> keys)
Deprecated.  
Defines keys to execute the mapper and a possibly defined reducer against. 
 | 
Job<KeyIn,ValueIn> | 
Job.onKeys(KeyIn... keys)
Deprecated.  
Defines keys to execute the mapper and a possibly defined reducer against. 
 | 
Job<KeyIn,ValueIn> | 
Job.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Deprecated.  
Defines the strategy to handle topology changes while executing the map reduce job. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractJob<KeyIn,ValueIn>
Base class for all map reduce job implementations 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Job<KeyIn,ValueIn> | 
AbstractJob.chunkSize(int chunkSize)  | 
Job<KeyIn,ValueIn> | 
AbstractJob.keyPredicate(KeyPredicate<? super KeyIn> predicate)  | 
Job<KeyIn,ValueIn> | 
AbstractJob.onKeys(Iterable<? extends KeyIn> keys)  | 
Job<KeyIn,ValueIn> | 
AbstractJob.onKeys(KeyIn... keys)  | 
Job<KeyIn,ValueIn> | 
AbstractJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KeyValueJob<KeyIn,ValueIn>
This class is the internal representation of a map reduce job. 
 | 
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.