public class MapReduceCacheLoaderTask
extends java.lang.Object
implements org.infinispan.persistence.spi.AdvancedCacheLoader.CacheLoaderTask
Modifier and Type | Field and Description |
---|---|
(package private) Collector |
collector |
(package private) Mapper |
mapper |
Constructor and Description |
---|
MapReduceCacheLoaderTask(Mapper mapper,
Collector collector) |
Modifier and Type | Method and Description |
---|---|
private java.lang.Object |
getValue(org.infinispan.marshall.core.MarshalledEntry marshalledEntry) |
void |
processEntry(org.infinispan.marshall.core.MarshalledEntry marshalledEntry,
org.infinispan.persistence.spi.AdvancedCacheLoader.TaskContext taskContext) |
public void processEntry(org.infinispan.marshall.core.MarshalledEntry marshalledEntry, org.infinispan.persistence.spi.AdvancedCacheLoader.TaskContext taskContext)
processEntry
in interface org.infinispan.persistence.spi.AdvancedCacheLoader.CacheLoaderTask
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()
private java.lang.Object getValue(org.infinispan.marshall.core.MarshalledEntry marshalledEntry)