|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Context | |
---|---|
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. |
Uses of Context in com.hazelcast.mapreduce |
---|
Methods in com.hazelcast.mapreduce with parameters of type Context | |
---|---|
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 it's 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 it's 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. |
Uses of Context in com.hazelcast.mapreduce.impl.task |
---|
Classes in com.hazelcast.mapreduce.impl.task that implement Context | |
---|---|
class |
DefaultContext<KeyIn,ValueIn>
This is the internal default implementation of a map reduce context mappers emit values to. |
Methods in com.hazelcast.mapreduce.impl.task with parameters of type Context | |
---|---|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |