Package | Description |
---|---|
com.hazelcast.mapreduce.impl.task |
This package contains the base implementation for a standard map reduce job.
|
Modifier and Type | Method and Description |
---|---|
<K,V> DefaultContext<K,V> |
JobSupervisor.getOrCreateContext(MapCombineTask mapCombineTask) |
Modifier and Type | Method and Description |
---|---|
void |
MapCombineTask.processMapping(int partitionId,
DefaultContext<KeyOut,ValueOut> context,
KeyValueSource<KeyIn,ValueIn> keyValueSource,
boolean partitionProcessor) |
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.