|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use Job | |
|---|---|
| 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. |
| Uses of Job in com.hazelcast.client.proxy |
|---|
| Methods in com.hazelcast.client.proxy that return Job | ||
|---|---|---|
|
ClientMapReduceProxy.newJob(KeyValueSource<K,V> source)
|
|
| Uses of Job in com.hazelcast.mapreduce |
|---|
| Methods in com.hazelcast.mapreduce that return Job | ||
|---|---|---|
Job<KeyIn,ValueIn> |
Job.chunkSize(int chunkSize)
Defines the number of elements per chunk. |
|
Job<KeyIn,ValueIn> |
Job.keyPredicate(KeyPredicate<KeyIn> predicate)
Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on. |
|
|
JobTracker.newJob(KeyValueSource<K,V> source)
Builds a Job instance for the given KeyValueSource instance. |
|
Job<KeyIn,ValueIn> |
Job.onKeys(Iterable<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. |
|
| Uses of Job in com.hazelcast.mapreduce.impl |
|---|
| Classes in com.hazelcast.mapreduce.impl that implement Job | |
|---|---|
class |
AbstractJob<KeyIn,ValueIn>
Base class for all map reduce job implementations |
| Methods in com.hazelcast.mapreduce.impl that return Job | |
|---|---|
Job<KeyIn,ValueIn> |
AbstractJob.chunkSize(int chunkSize)
|
Job<KeyIn,ValueIn> |
AbstractJob.keyPredicate(KeyPredicate<KeyIn> predicate)
|
Job<KeyIn,ValueIn> |
AbstractJob.onKeys(Iterable<KeyIn> keys)
|
Job<KeyIn,ValueIn> |
AbstractJob.onKeys(KeyIn... keys)
|
Job<KeyIn,ValueIn> |
AbstractJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
|
| Uses of Job in com.hazelcast.mapreduce.impl.task |
|---|
| Classes in com.hazelcast.mapreduce.impl.task that implement Job | |
|---|---|
class |
KeyValueJob<KeyIn,ValueIn>
This class is the internal representation of a map reduce job. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||