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)
Defines the number of elements per chunk.
|
Job<KeyIn,ValueIn> |
Job.keyPredicate(KeyPredicate<? super KeyIn> predicate)
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)
Builds a
Job instance for the given KeyValueSource instance. |
Job<KeyIn,ValueIn> |
Job.onKeys(Iterable<? extends KeyIn> keys)
Defines keys to execute the mapper and a possibly defined reducer against.
|
Job<KeyIn,ValueIn> |
Job.onKeys(KeyIn... keys)
Defines keys to execute the mapper and a possibly defined reducer against.
|
Job<KeyIn,ValueIn> |
Job.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
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 © 2016 Hazelcast, Inc.. All Rights Reserved.