Package | Description |
---|---|
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.impl.task |
This package contains the base implementation for a standard map reduce job.
|
Modifier and Type | Method and Description |
---|---|
void |
LifecycleMapper.finalized(Context<KeyOut,ValueOut> context)
This method is called after the
Mapper.map(Object, Object, Context) method is executed for every value and
can be used to finalize the internal state of the mapper or to emit a special value. |
void |
LifecycleMapperAdapter.finalized(Context<KeyOut,ValueOut> context)
This method is called after the
Mapper.map(Object, Object, Context) method is executed for every value and
can be used to finalize the internal state of the mapper or to emit a special value. |
void |
LifecycleMapper.initialize(Context<KeyOut,ValueOut> context)
This method is called before the
Mapper.map(Object, Object, Context) method is executed for every value and
can be used to initialize the internal state of the mapper or to emit a special value. |
void |
LifecycleMapperAdapter.initialize(Context<KeyOut,ValueOut> context)
This method is called before the
Mapper.map(Object, Object, Context) method is executed for every value and
can be used to initialize the internal state of the mapper or to emit a special value. |
void |
Mapper.map(KeyIn key,
ValueIn value,
Context<KeyOut,ValueOut> context)
The map method is called for every single key-value pair in the bound
KeyValueSource instance
on this cluster node and partition.Due to its nature of a DataGrid, Hazelcast distributes values all over the cluster and so this method is executed on multiple servers at the same time. If you want to know more about the implementation of MapReduce algorithms read the Google Whitepaper on MapReduce. |
abstract void |
LifecycleMapperAdapter.map(KeyIn key,
ValueIn value,
Context<KeyOut,ValueOut> context)
The map method is called for every single key-value pair in the bound
KeyValueSource instance
on this cluster node and partition.Due to its nature of a DataGrid, Hazelcast distributes values all over the cluster and so this method is executed on multiple servers at the same time. If you want to know more about the implementation of MapReduce algorithms read the Google Whitepaper on MapReduce. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultContext<KeyIn,ValueIn>
This is the internal default implementation of a map reduce context mappers emit values to.
|
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) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.