Package | Description |
---|---|
com.hazelcast.client.impl.protocol.task.mapreduce |
Client protocol tasks implementations for map reduce
|
com.hazelcast.mapreduce |
This package contains the MapReduce API definition for Hazelcast.
All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
com.hazelcast.mapreduce.aggregation |
This package contains the aggregation API and the convenience helper classes
to retrieve predefined aggregation implementations.
|
com.hazelcast.mapreduce.aggregation.impl |
This package contains a set of predefined aggregation implementations
|
com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
com.hazelcast.mapreduce.impl.operation |
This package contains all remote operations that are needed to control work on
supervising or worker nodes.
|
com.hazelcast.mapreduce.impl.task |
This package contains the base implementation for a standard map reduce job.
|
Modifier and Type | Method and Description |
---|---|
protected Mapper |
MapReduceForMapMessageTask.getMapper() |
protected Mapper |
MapReduceForSetMessageTask.getMapper() |
protected abstract Mapper |
AbstractMapReduceTask.getMapper() |
protected Mapper |
MapReduceForCustomMessageTask.getMapper() |
protected Mapper |
MapReduceForListMessageTask.getMapper() |
protected Mapper |
MapReduceForMultiMapMessageTask.getMapper() |
Modifier and Type | Interface and Description |
---|---|
interface |
LifecycleMapper<KeyIn,ValueIn,KeyOut,ValueOut>
The LifecycleMapper interface is a more sophisticated version of
Mapper normally used for more complex
algorithms with a need for initialization and finalization. |
Modifier and Type | Class and Description |
---|---|
class |
LifecycleMapperAdapter<KeyIn,ValueIn,KeyOut,ValueOut>
The abstract LifecycleMapperAdapter superclass is used to ease building mappers for the
Job . |
Modifier and Type | Method and Description |
---|---|
<KeyOut,ValueOut> |
Job.mapper(Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper)
Defines the mapper for this task.
|
Modifier and Type | Method and Description |
---|---|
Mapper |
Aggregation.getMapper(Supplier<Key,?,Supplied> supplier)
Returns the Mapper for this aggregation.
|
Modifier and Type | Field and Description |
---|---|
protected Mapper<KeyIn,ValueIn,?,?> |
AbstractJob.mapper |
Modifier and Type | Method and Description |
---|---|
<KeyOut,ValueOut> |
AbstractJob.mapper(Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper) |
Constructor and Description |
---|
KeyValueJobOperation(String name,
String jobId,
int chunkSize,
KeyValueSource<K,V> keyValueSource,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
boolean communicateStats,
TopologyChangedStrategy topologyChangedStrategy) |
Modifier and Type | Method and Description |
---|---|
Mapper |
JobTaskConfiguration.getMapper() |
Modifier and Type | Method and Description |
---|---|
void |
KeyValueSourceMappingPhase.executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource,
Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper,
Context<KeyOut,ValueOut> context) |
protected abstract void |
MappingPhase.executeMappingPhase(KeyValueSource<KeyIn,ValueIn> keyValueSource,
Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper,
Context<KeyOut,ValueOut> context) |
Constructor and Description |
---|
JobTaskConfiguration(Address jobOwner,
NodeEngine nodeEngine,
int chunkSize,
String name,
String jobId,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
KeyValueSource keyValueSource,
boolean communicateStats,
TopologyChangedStrategy topologyChangedStrategy) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.