Package | Description |
---|---|
com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
com.hazelcast.mapreduce.impl.task |
This package contains the base implementation for a standard map reduce job.
|
Modifier and Type | Method and Description |
---|---|
JobSupervisor |
MapReduceService.createJobSupervisor(JobTaskConfiguration configuration) |
JobSupervisor |
MapReduceService.getJobSupervisor(String name,
String jobId) |
Modifier and Type | Method and Description |
---|---|
static JobProcessInformationImpl |
MapReduceUtil.createJobProcessInformation(JobTaskConfiguration configuration,
JobSupervisor supervisor) |
boolean |
MapReduceService.destroyJobSupervisor(JobSupervisor supervisor) |
static void |
MapReduceUtil.notifyRemoteException(JobSupervisor supervisor,
Throwable throwable) |
Modifier and Type | Method and Description |
---|---|
static <K,V> Map<Address,Map<K,V>> |
MapCombineTask.mapResultToMember(JobSupervisor supervisor,
Map<K,V> result) |
Constructor and Description |
---|
JobProcessInformationImpl(int partitionCount,
JobSupervisor supervisor) |
MapCombineTask(JobTaskConfiguration configuration,
JobSupervisor supervisor,
MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase) |
MemberAssigningJobProcessInformationImpl(int partitionCount,
JobSupervisor supervisor) |
ReducerTask(String name,
String jobId,
JobSupervisor supervisor) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.