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 | Field and Description |
---|---|
protected MapReduceService |
AbstractJobTracker.mapReduceService |
Modifier and Type | Method and Description |
---|---|
static void |
MapReduceUtil.enforcePartitionTableWarmup(MapReduceService mapReduceService) |
static <V> List<V> |
MapReduceUtil.executeOperation(Collection<Member> members,
OperationFactory operationFactory,
MapReduceService mapReduceService,
NodeEngine nodeEngine) |
static <V> V |
MapReduceUtil.executeOperation(Operation operation,
Address address,
MapReduceService mapReduceService,
NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
MapReduceService |
JobSupervisor.getMapReduceService() |
Constructor and Description |
---|
JobSupervisor(JobTaskConfiguration configuration,
AbstractJobTracker jobTracker,
boolean ownerNode,
MapReduceService mapReduceService) |
KeyValueJob(String name,
AbstractJobTracker jobTracker,
NodeEngine nodeEngine,
MapReduceService mapReduceService,
KeyValueSource<KeyIn,ValueIn> keyValueSource) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.