org.infinispan.distexec.mapreduce

Class MapReduceCacheLoaderTask

java.lang.Object

org.infinispan.distexec.mapreduce.MapReduceCacheLoaderTask

All Implemented Interfaces:

AdvancedCacheLoader.CacheLoaderTask

public class MapReduceCacheLoaderTask
extends Object
implements AdvancedCacheLoader.CacheLoaderTask

Since:

6.0

Author:

Mircea Markus

Constructor Summary

Constructors

Constructor and Description
MapReduceCacheLoaderTask(Mapper mapper, Collector collector)

Method Summary

Methods

Modifier and Type	Method and Description
void	processEntry(MarshalledEntry marshalledEntry, AdvancedCacheLoader.TaskContext taskContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapReduceCacheLoaderTask

public MapReduceCacheLoaderTask(Mapper mapper,
                        Collector collector)

Method Detail

processEntry

public void processEntry(MarshalledEntry marshalledEntry,
                AdvancedCacheLoader.TaskContext taskContext)

Specified by:

processEntry in interface AdvancedCacheLoader.CacheLoaderTask

Parameters:

marshalledEntry - an iterated entry. Note that MarshalledEntry.getValue() might be null if the fetchValue parameter passed to AdvancedCacheLoader.process(KeyFilter, org.infinispan.persistence.spi.AdvancedCacheLoader.CacheLoaderTask, java.util.concurrent.Executor, boolean, boolean) is false.

taskContext - allows the implementors to decide when to stop the iteration by invoking AdvancedCacheLoader.TaskContext.stop()