org.infinispan.distexec.mapreduce

Class MapReduceCacheLoaderTask<KIn,VIn,KOut,VOut>

java.lang.Object

org.infinispan.distexec.mapreduce.MapReduceCacheLoaderTask<KIn,VIn,KOut,VOut>

All Implemented Interfaces:

AdvancedCacheLoader.CacheLoaderTask<KIn,VIn>

public class MapReduceCacheLoaderTask<KIn,VIn,KOut,VOut>
extends Object
implements AdvancedCacheLoader.CacheLoaderTask<KIn,VIn>

This is an internal class, not intended to be used by clients.

Since:

6.0

Author:

Mircea Markus

Constructor Summary

Constructors

Constructor and Description
MapReduceCacheLoaderTask(Mapper<KIn,VIn,KOut,VOut> mapper, Collector<KOut,VOut> collector)

Method Summary

Methods

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

Constructor Detail

MapReduceCacheLoaderTask

public MapReduceCacheLoaderTask(Mapper<KIn,VIn,KOut,VOut> mapper,
                        Collector<KOut,VOut> collector)

Method Detail

processEntry

public void processEntry(MarshalledEntry<KIn,VIn> marshalledEntry,
                AdvancedCacheLoader.TaskContext taskContext)

Specified by:

processEntry in interface AdvancedCacheLoader.CacheLoaderTask<KIn,VIn>

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()