|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ReducingJob | |
---|---|
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. |
Uses of ReducingJob in com.hazelcast.mapreduce |
---|
Methods in com.hazelcast.mapreduce that return ReducingJob | ||
---|---|---|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.chunkSize(int chunkSize)
Defines the number of elements per chunk. |
|
|
MappingJob.combiner(CombinerFactory<KeyIn,ValueIn,ValueOut> combinerFactory)
Defines the CombinerFactory for this task. |
|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.keyPredicate(KeyPredicate<EntryKey> predicate)
Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on. |
|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.onKeys(EntryKey... keys)
Defines keys to execute the mapper and a possibly defined reducer against. |
|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.onKeys(Iterable<EntryKey> keys)
Defines keys to execute the mapper and a possibly defined reducer against. |
|
ReducingJob<EntryKey,KeyIn,ValueIn> |
ReducingJob.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job. |
Uses of ReducingJob in com.hazelcast.mapreduce.impl |
---|
Classes in com.hazelcast.mapreduce.impl that implement ReducingJob | |
---|---|
protected class |
AbstractJob.ReducingJobImpl<EntryKey,Key,Value>
This class is just used to comply to the public DSL style API |
Methods in com.hazelcast.mapreduce.impl that return ReducingJob | ||
---|---|---|
ReducingJob<EntryKey,Key,Value> |
AbstractJob.ReducingJobImpl.chunkSize(int chunkSize)
|
|
|
AbstractJob.MappingJobImpl.combiner(CombinerFactory<Key,Value,ValueOut> combinerFactory)
|
|
ReducingJob<EntryKey,Key,Value> |
AbstractJob.ReducingJobImpl.keyPredicate(KeyPredicate<EntryKey> predicate)
|
|
ReducingJob<EntryKey,Key,Value> |
AbstractJob.ReducingJobImpl.onKeys(EntryKey... keys)
|
|
ReducingJob<EntryKey,Key,Value> |
AbstractJob.ReducingJobImpl.onKeys(Iterable<EntryKey> keys)
|
|
ReducingJob<EntryKey,Key,Value> |
AbstractJob.ReducingJobImpl.topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |