org.infinispan.persistence.spi

Interface AdvancedCacheLoader.CacheLoaderTask<K,V>

All Known Implementing Classes:

MapReduceCacheLoaderTask

Enclosing interface:

AdvancedCacheLoader<K,V>

@ThreadSafe
public static interface AdvancedCacheLoader.CacheLoaderTask<K,V>

Offers a callback to be invoked for parallel iteration over the entries in an external store. Implementors should be thread safe.

Method Summary

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

Method Detail

processEntry

void processEntry(MarshalledEntry<K,V> marshalledEntry,
                  AdvancedCacheLoader.TaskContext taskContext)
           throws InterruptedException

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

Throws:

InterruptedException