EntryKey
- type of the original base keyKey
- type of the key at that processing stateValue
- type of the value at that processing stateprotected class AbstractJob.ReducingSubmittableJobImpl<EntryKey,Key,Value> extends Object implements ReducingSubmittableJob<EntryKey,Key,Value>
Modifier | Constructor and Description |
---|---|
protected |
AbstractJob.ReducingSubmittableJobImpl() |
Modifier and Type | Method and Description |
---|---|
ReducingSubmittableJob<EntryKey,Key,Value> |
chunkSize(int chunkSize)
Defines the number of elements per chunk.
|
ReducingSubmittableJob<EntryKey,Key,Value> |
keyPredicate(KeyPredicate<EntryKey> predicate)
Defines the
KeyPredicate implementation to preselect keys the MapReduce task
will be executed on. |
ReducingSubmittableJob<EntryKey,Key,Value> |
onKeys(EntryKey... keys)
Defines keys to execute the mapper and a possibly defined reducer against.
|
ReducingSubmittableJob<EntryKey,Key,Value> |
onKeys(Iterable<EntryKey> keys)
Defines keys to execute the mapper and a possibly defined reducer against.
|
JobCompletableFuture<Map<Key,Value>> |
submit()
Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes.
|
<ValueOut> JobCompletableFuture<ValueOut> |
submit(Collator<Map.Entry<Key,Value>,ValueOut> collator)
Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes and executes the
collator before returning the final result.
|
ReducingSubmittableJob<EntryKey,Key,Value> |
topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
Defines the strategy to handle topology changes while executing the map reduce job.
|
protected AbstractJob.ReducingSubmittableJobImpl()
public ReducingSubmittableJob<EntryKey,Key,Value> onKeys(Iterable<EntryKey> keys)
ReducingSubmittableJob
onKeys
in interface ReducingSubmittableJob<EntryKey,Key,Value>
keys
- keys to be executed againstpublic ReducingSubmittableJob<EntryKey,Key,Value> onKeys(EntryKey... keys)
ReducingSubmittableJob
onKeys
in interface ReducingSubmittableJob<EntryKey,Key,Value>
keys
- keys to be executed againstpublic ReducingSubmittableJob<EntryKey,Key,Value> keyPredicate(KeyPredicate<EntryKey> predicate)
ReducingSubmittableJob
KeyPredicate
implementation to preselect keys the MapReduce task
will be executed on. Preselecting keys can speed up the job massively.ReducingSubmittableJob.onKeys(Iterable)
or ReducingSubmittableJob.onKeys(Object...)
to define a
range of known and evaluated keys.keyPredicate
in interface ReducingSubmittableJob<EntryKey,Key,Value>
predicate
- predicate implementation to be used to evaluate keyspublic ReducingSubmittableJob<EntryKey,Key,Value> chunkSize(int chunkSize)
ReducingSubmittableJob
ReducerFactory
is defined, the chunk will be sent to the nodes that
are responsible for the emitted keys.chunkSize
in interface ReducingSubmittableJob<EntryKey,Key,Value>
chunkSize
- the number of elements per chunkpublic ReducingSubmittableJob<EntryKey,Key,Value> topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)
ReducingSubmittableJob
TopologyChangedStrategy
.topologyChangedStrategy
in interface ReducingSubmittableJob<EntryKey,Key,Value>
topologyChangedStrategy
- strategy to handle topology changes while executing the map reduce jobpublic JobCompletableFuture<Map<Key,Value>> submit()
ReducingSubmittableJob
submit
in interface ReducingSubmittableJob<EntryKey,Key,Value>
public <ValueOut> JobCompletableFuture<ValueOut> submit(Collator<Map.Entry<Key,Value>,ValueOut> collator)
ReducingSubmittableJob
submit
in interface ReducingSubmittableJob<EntryKey,Key,Value>
ValueOut
- type of the collated valuecollator
- collator to use after map and reduceCopyright © 2016 Hazelcast, Inc.. All Rights Reserved.