com.hazelcast.mapreduce.impl.task
Class KeyValueJob<KeyIn,ValueIn>

java.lang.Object
  com.hazelcast.mapreduce.impl.AbstractJob<KeyIn,ValueIn>
      com.hazelcast.mapreduce.impl.task.KeyValueJob<KeyIn,ValueIn>

Type Parameters:

KeyIn - type of the key

ValueIn - type of the value

All Implemented Interfaces:

Job<KeyIn,ValueIn>

public class KeyValueJob<KeyIn,ValueIn>
extends AbstractJob<KeyIn,ValueIn>

This class is the internal representation of a map reduce job. It is responsible for requesting the preparation, processing and sets up the future to retrieve the value in a fully reactive way.

Nested Class Summary

Nested classes/interfaces inherited from class com.hazelcast.mapreduce.impl.AbstractJob

AbstractJob.MappingJobImpl<EntryKey,Key,Value>, AbstractJob.ReducingJobImpl<EntryKey,Key,Value>, AbstractJob.ReducingSubmittableJobImpl<EntryKey,Key,Value>

Field Summary

Fields inherited from class com.hazelcast.mapreduce.impl.AbstractJob

chunkSize, combinerFactory, jobTracker, keys, keyValueSource, mapper, name, predicate, reducerFactory, topologyChangedStrategy

Constructor Summary

KeyValueJob(String name, AbstractJobTracker jobTracker, NodeEngine nodeEngine, MapReduceService mapReduceService, KeyValueSource<KeyIn,ValueIn> keyValueSource)

Method Summary

protected <T> JobCompletableFuture<T>

invoke(Collator collator)

Methods inherited from class com.hazelcast.mapreduce.impl.AbstractJob

chunkSize, keyPredicate, mapper, onKeys, onKeys, prepareKeyPredicate, submit, topologyChangedStrategy

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KeyValueJob

public KeyValueJob(String name,
                   AbstractJobTracker jobTracker,
                   NodeEngine nodeEngine,
                   MapReduceService mapReduceService,
                   KeyValueSource<KeyIn,ValueIn> keyValueSource)

Method Detail

invoke

protected <T> JobCompletableFuture<T> invoke(Collator collator)

Specified by:

invoke in class AbstractJob<KeyIn,ValueIn>