KeyIn
- type of the keyValueIn
- type of the valuepublic class KeyValueJob<KeyIn,ValueIn> extends AbstractJob<KeyIn,ValueIn>
AbstractJob.MappingJobImpl<EntryKey,Key,Value>, AbstractJob.ReducingJobImpl<EntryKey,Key,Value>, AbstractJob.ReducingSubmittableJobImpl<EntryKey,Key,Value>
chunkSize, combinerFactory, jobTracker, keys, keyValueSource, mapper, name, predicate, reducerFactory, topologyChangedStrategy
Constructor and Description |
---|
KeyValueJob(String name,
AbstractJobTracker jobTracker,
NodeEngine nodeEngine,
MapReduceService mapReduceService,
KeyValueSource<KeyIn,ValueIn> keyValueSource) |
Modifier and Type | Method and Description |
---|---|
protected <T> JobCompletableFuture<T> |
invoke(Collator collator) |
chunkSize, keyPredicate, mapper, onKeys, onKeys, prepareKeyPredicate, submit, topologyChangedStrategy
public KeyValueJob(String name, AbstractJobTracker jobTracker, NodeEngine nodeEngine, MapReduceService mapReduceService, KeyValueSource<KeyIn,ValueIn> keyValueSource)
protected <T> JobCompletableFuture<T> invoke(Collator collator)
invoke
in class AbstractJob<KeyIn,ValueIn>
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.