Uses of Interface
com.hazelcast.mapreduce.KeyPredicate

Packages that use KeyPredicate

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.client	This package contains request and response classes for communication between cluster members and Hazelcast native clients
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.

Uses of KeyPredicate in com.hazelcast.client.impl.protocol.task.mapreduce

Methods in com.hazelcast.client.impl.protocol.task.mapreduce that return KeyPredicate

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()

Uses of KeyPredicate in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce with parameters of type KeyPredicate

Modifier and Type	Method and Description
ReducingJob<EntryKey,KeyIn,ValueIn>	ReducingJob.keyPredicate(KeyPredicate<EntryKey> predicate) Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.
MappingJob<EntryKey,KeyIn,ValueIn>	MappingJob.keyPredicate(KeyPredicate<EntryKey> predicate) Defines the KeyPredicate implementation to preselect keys that the MapReduce task will be executed on.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	ReducingSubmittableJob.keyPredicate(KeyPredicate<EntryKey> predicate) Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.
Job<KeyIn,ValueIn>	Job.keyPredicate(KeyPredicate<KeyIn> predicate) Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.

Uses of KeyPredicate in com.hazelcast.mapreduce.aggregation

Methods in com.hazelcast.mapreduce.aggregation with parameters of type KeyPredicate

Modifier and Type	Method and Description
static <KeyIn,ValueIn,ValueOut> Supplier<KeyIn,ValueIn,ValueOut>	Supplier.fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate) The predefined Supplier selects values using the given KeyPredicate and does not perform any kind of data transformation.
static <KeyIn,ValueIn,ValueOut> Supplier<KeyIn,ValueIn,ValueOut>	Supplier.fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate, Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier) The predefined Supplier selects values using the given KeyPredicate and chains the filtered value to the given Supplier which might perform data transformation.

Uses of KeyPredicate in com.hazelcast.mapreduce.aggregation.impl

Constructors in com.hazelcast.mapreduce.aggregation.impl with parameters of type KeyPredicate

Constructor and Description
KeyPredicateSupplier(KeyPredicate<KeyIn> keyPredicate)
KeyPredicateSupplier(KeyPredicate<KeyIn> keyPredicate, Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)

Uses of KeyPredicate in com.hazelcast.mapreduce.impl

Fields in com.hazelcast.mapreduce.impl declared as KeyPredicate

Modifier and Type	Field and Description
protected KeyPredicate<KeyIn>	AbstractJob.predicate

Methods in com.hazelcast.mapreduce.impl with parameters of type KeyPredicate

Modifier and Type	Method and Description
MappingJob<EntryKey,Key,Value>	AbstractJob.MappingJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate)
ReducingJob<EntryKey,Key,Value>	AbstractJob.ReducingJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate)
ReducingSubmittableJob<EntryKey,Key,Value>	AbstractJob.ReducingSubmittableJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate)
Job<KeyIn,ValueIn>	AbstractJob.keyPredicate(KeyPredicate<KeyIn> predicate)

Uses of KeyPredicate in com.hazelcast.mapreduce.impl.client

Fields in com.hazelcast.mapreduce.impl.client declared as KeyPredicate

Modifier and Type	Field and Description
protected KeyPredicate	ClientMapReduceRequest.predicate

Constructors in com.hazelcast.mapreduce.impl.client with parameters of type KeyPredicate

Constructor and Description
ClientMapReduceRequest(String name, String jobId, Collection keys, KeyPredicate predicate, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, KeyValueSource keyValueSource, int chunkSize, TopologyChangedStrategy topologyChangedStrategy)

Uses of KeyPredicate in com.hazelcast.mapreduce.impl.operation

Constructors in com.hazelcast.mapreduce.impl.operation with parameters of type KeyPredicate

Constructor and Description
StartProcessingJobOperation(String name, String jobId, Collection<K> keys, KeyPredicate<K> predicate)

Uses of KeyPredicate in com.hazelcast.mapreduce.impl.task

Constructors in com.hazelcast.mapreduce.impl.task with parameters of type KeyPredicate

Constructor and Description
KeyValueSourceMappingPhase(Collection<KeyIn> keys, KeyPredicate<KeyIn> predicate)
MappingPhase(Collection<KeyIn> keys, KeyPredicate<KeyIn> predicate)