com.hazelcast.mapreduce
Interface ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>

Type Parameters:

EntryKey - type of the original input key

KeyIn - type of the key that is used for reducing

ValueIn - type of value used as input value type

All Known Implementing Classes:

AbstractJob.ReducingSubmittableJobImpl

@Beta
public interface ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>

This interface describes a submittable mapreduce Job.
For further information Job.

Since:

3.2

See Also:

Job

Method Summary

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	chunkSize(int chunkSize) Defines the number of elements per chunk.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	keyPredicate(KeyPredicate<EntryKey> predicate) Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	onKeys(EntryKey... keys) Defines keys to execute the mapper and a possibly defined reducer against.
ReducingSubmittableJob<EntryKey,KeyIn,ValueIn>	onKeys(Iterable<EntryKey> keys) Defines keys to execute the mapper and a possibly defined reducer against.
JobCompletableFuture<Map<KeyIn,ValueIn>>	submit() Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes
<ValueOut> JobCompletableFuture<ValueOut>	submit(Collator<Map.Entry<KeyIn,ValueIn>,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,KeyIn,ValueIn>	topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy) Defines the strategy to handle topology changes while executing the map reduce job.

Method Detail

onKeys

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> onKeys(Iterable<EntryKey> keys)

Defines keys to execute the mapper and a possibly defined reducer against. If keys are known before submitting the task setting them can improve execution speed.

Parameters:

keys - keys to be executed against

Returns:

instance of this Job with generics changed on usage

onKeys

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> onKeys(EntryKey... keys)

Defines keys to execute the mapper and a possibly defined reducer against. If keys are known before submitting the task setting them can improve execution speed.

Parameters:

keys - keys to be executed against

Returns:

instance of this Job with generics changed on usage

keyPredicate

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> keyPredicate(KeyPredicate<EntryKey> predicate)

Defines the KeyPredicate implementation to preselect keys the MapReduce task will be executed on. Preselecting keys can speed up the job massively.
This method can be used in conjunction with onKeys(Iterable) or onKeys(Object...) to define a range of known and evaluated keys.

Parameters:

predicate - predicate implementation to be used to evaluate keys

Returns:

instance of this Job with generics changed on usage

chunkSize

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> chunkSize(int chunkSize)

Defines the number of elements per chunk. Whenever the chunk size is reached and a ReducerFactory is defined the chunk will be send to the nodes that is responsible for the emitted keys.
Please note, that chunks are deactivated when no ReducerFactory is defined

Parameters:

chunkSize - the number of elements per chunk

Returns:

instance of this Job with generics changed on usage

topologyChangedStrategy

ReducingSubmittableJob<EntryKey,KeyIn,ValueIn> topologyChangedStrategy(TopologyChangedStrategy topologyChangedStrategy)

Defines the strategy to handle topology changes while executing the map reduce job. For further information see TopologyChangedStrategy.

Parameters:

topologyChangedStrategy - strategy to use

Returns:

instance of this Job with generics changed on usage

submit

JobCompletableFuture<Map<KeyIn,ValueIn>> submit()

Submits the task to Hazelcast and executes the defined mapper and reducer on all cluster nodes

Returns:

JobCompletableFuture to wait for mapped and possibly reduced result

submit

<ValueOut> JobCompletableFuture<ValueOut> submit(Collator<Map.Entry<KeyIn,ValueIn>,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.

Type Parameters:

ValueOut - type of the collated value

Parameters:

collator - collator to use after map and reduce

Returns:

JobCompletableFuture to wait for mapped and possibly reduced result