| Package | Description | 
|---|---|
| com.hazelcast.client.impl.protocol.task.mapreduce | Client protocol tasks implementations for map reduce | 
| 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.aggregation | This package contains the aggregation API and the convenience helper classes
 to retrieve predefined aggregation implementations. | 
| com.hazelcast.mapreduce.aggregation.impl | This package contains a set of predefined aggregation implementations | 
| com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework
 internals. | 
| com.hazelcast.mapreduce.impl.operation | This package contains all remote operations that are needed to control work on
 supervising or worker nodes. | 
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected KeyPredicate | MapReduceForMapMessageTask. getPredicate() | 
| protected KeyPredicate | MapReduceForSetMessageTask. getPredicate() | 
| protected abstract KeyPredicate | AbstractMapReduceTask. getPredicate() | 
| protected KeyPredicate | MapReduceForCustomMessageTask. getPredicate() | 
| protected KeyPredicate | MapReduceForListMessageTask. getPredicate() | 
| protected KeyPredicate | MapReduceForMultiMapMessageTask. getPredicate() | 
| Modifier and Type | Method and Description | 
|---|---|
| MappingJob<EntryKey,KeyIn,ValueIn> | MappingJob. keyPredicate(KeyPredicate<? super EntryKey> predicate)Deprecated.  Defines the  KeyPredicateimplementation to preselect keys that the MapReduce task will be executed on. | 
| Job<KeyIn,ValueIn> | Job. keyPredicate(KeyPredicate<? super KeyIn> predicate)Deprecated.  Defines the  KeyPredicateimplementation to preselect keys the MapReduce task will be executed on. | 
| ReducingJob<EntryKey,KeyIn,ValueIn> | ReducingJob. keyPredicate(KeyPredicate<EntryKey> predicate)Deprecated.  Defines the  KeyPredicateimplementation to preselect keys the MapReduce task will be executed on. | 
| ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> | ReducingSubmittableJob. keyPredicate(KeyPredicate<EntryKey> predicate)Deprecated.  Defines the  KeyPredicateimplementation to preselect keys the MapReduce task
 will be executed on. | 
| Modifier and Type | Method and Description | 
|---|---|
| static <KeyIn,ValueIn,ValueOut> | Supplier. fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate)Deprecated.  The predefined Supplier selects values using the given  KeyPredicateand does not perform any kind of data transformation. | 
| static <KeyIn,ValueIn,ValueOut> | Supplier. fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate,
                Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)Deprecated.  The predefined Supplier selects values using the given  KeyPredicateand chains the filtered value to the given Supplier which might perform data transformation. | 
| Constructor and Description | 
|---|
| KeyPredicateSupplier(KeyPredicate<KeyIn> keyPredicate) | 
| KeyPredicateSupplier(KeyPredicate<KeyIn> keyPredicate,
                    Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected KeyPredicate<? super KeyIn> | AbstractJob. predicate | 
| Modifier and Type | Method and Description | 
|---|---|
| MappingJob<EntryKey,Key,Value> | AbstractJob.MappingJobImpl. keyPredicate(KeyPredicate<? super EntryKey> predicate) | 
| Job<KeyIn,ValueIn> | AbstractJob. keyPredicate(KeyPredicate<? super KeyIn> predicate) | 
| ReducingJob<EntryKey,Key,Value> | AbstractJob.ReducingJobImpl. keyPredicate(KeyPredicate<EntryKey> predicate) | 
| ReducingSubmittableJob<EntryKey,Key,Value> | AbstractJob.ReducingSubmittableJobImpl. keyPredicate(KeyPredicate<EntryKey> predicate) | 
| Constructor and Description | 
|---|
| StartProcessingJobOperation(String name,
                           String jobId,
                           Collection<K> keys,
                           KeyPredicate<? super K> predicate) | 
| Constructor and Description | 
|---|
| KeyValueSourceMappingPhase(Collection<? extends KeyIn> keys,
                          KeyPredicate<? super KeyIn> predicate) | 
| MappingPhase(Collection<? extends KeyIn> keys,
            KeyPredicate<? super KeyIn> predicate) | 
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.