|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use KeyPredicate | |
---|---|
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.mapreduce |
---|
Methods in com.hazelcast.mapreduce with parameters of type KeyPredicate | |
---|---|
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 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 | ||
---|---|---|
static
|
Supplier.fromKeyPredicate(KeyPredicate<KeyIn> keyPredicate)
The predefined Supplier selects values using the given KeyPredicate
and does not perform any kind of data transformation. |
|
static
|
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 | |
---|---|
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 | |
---|---|
protected KeyPredicate<KeyIn> |
AbstractJob.predicate
|
Methods in com.hazelcast.mapreduce.impl with parameters of type KeyPredicate | |
---|---|
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 | |
---|---|
protected KeyPredicate |
ClientMapReduceRequest.predicate
|
Constructors in com.hazelcast.mapreduce.impl.client with parameters of type KeyPredicate | |
---|---|
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 | |
---|---|
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 | |
---|---|
KeyValueSourceMappingPhase(Collection<KeyIn> keys,
KeyPredicate<KeyIn> predicate)
|
|
MappingPhase(Collection<KeyIn> keys,
KeyPredicate<KeyIn> predicate)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |