| Package | Description | 
|---|---|
| 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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MappingJob<EntryKey,KeyIn,ValueIn> | 
MappingJob.chunkSize(int chunkSize)
Deprecated.  
Defines the number of elements per chunk. 
 | 
MappingJob<EntryKey,KeyIn,ValueIn> | 
MappingJob.keyPredicate(KeyPredicate<? super EntryKey> predicate)
Deprecated.  
Defines the  
KeyPredicate implementation to preselect keys that the MapReduce task will be executed on. | 
<KeyOut,ValueOut> | 
Job.mapper(Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper)
Deprecated.  
Defines the mapper for this task. 
 | 
MappingJob<EntryKey,KeyIn,ValueIn> | 
MappingJob.onKeys(EntryKey... keys)
Deprecated.  
Defines keys to execute the mapper and a possibly defined reducer against. 
 | 
MappingJob<EntryKey,KeyIn,ValueIn> | 
MappingJob.onKeys(Iterable<? extends EntryKey> keys)
Deprecated.  
Defines keys to execute the mapper and a possibly defined reducer against. 
 | 
MappingJob<EntryKey,KeyIn,ValueIn> | 
MappingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Deprecated.  
Defines the strategy to handle topology changes while executing the map reduce job. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
protected class  | 
AbstractJob.MappingJobImpl<EntryKey,Key,Value>
This class is just used to comply to the public DSL style API 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MappingJob<EntryKey,Key,Value> | 
AbstractJob.MappingJobImpl.chunkSize(int chunkSize)  | 
MappingJob<EntryKey,Key,Value> | 
AbstractJob.MappingJobImpl.keyPredicate(KeyPredicate<? super EntryKey> predicate)  | 
<KeyOut,ValueOut> | 
AbstractJob.mapper(Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper)  | 
MappingJob<EntryKey,Key,Value> | 
AbstractJob.MappingJobImpl.onKeys(EntryKey... keys)  | 
MappingJob<EntryKey,Key,Value> | 
AbstractJob.MappingJobImpl.onKeys(Iterable<? extends EntryKey> keys)  | 
MappingJob<EntryKey,Key,Value> | 
AbstractJob.MappingJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)  | 
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.