@ThreadSafe public interface AdvancedCacheLoader<K,V> extends CacheLoader<K,V>
CacheLoader
interface that allows processing parallel iteration over the
existing entries.Modifier and Type | Interface and Description |
---|---|
static interface |
AdvancedCacheLoader.CacheLoaderTask<K,V>
Offers a callback to be invoked for parallel iteration over the entries in an external store.
|
static interface |
AdvancedCacheLoader.KeyFilter<K>
Used during the parallel iteration to filter-out the keys that the caller is not interested in.
|
static interface |
AdvancedCacheLoader.TaskContext
Used during the parallel iteration in order to offer the
AdvancedCacheLoader.CacheLoaderTask a way of canceling the entry
iteration. |
Modifier and Type | Method and Description |
---|---|
void |
process(AdvancedCacheLoader.KeyFilter<K> filter,
AdvancedCacheLoader.CacheLoaderTask<K,V> task,
Executor executor,
boolean fetchValue,
boolean fetchMetadata)
Iterates in parallel over the entries in the storage using the threads from the executor pool.
|
int |
size()
Returns the number of elements in the store.
|
contains, init, load
void process(AdvancedCacheLoader.KeyFilter<K> filter, AdvancedCacheLoader.CacheLoaderTask<K,V> task, Executor executor, boolean fetchValue, boolean fetchMetadata)
CacheLoaderTask#processEntry(org.infinispan.marshall.core.MarshalledEntry, TaskContext)
is
invoked. Before passing an entry to the callback task, the entry should be validated against the filter.
Implementors should build an AdvancedCacheLoader.TaskContext
instance (implementation) that is fed to the AdvancedCacheLoader.CacheLoaderTask
on every invocation. The AdvancedCacheLoader.CacheLoaderTask
might invoke AdvancedCacheLoader.TaskContext.stop()
at any time, so implementors of this method
should verify TaskContext's state for early termination of iteration. The method should only return once the
iteration is complete or as soon as possible in the case TaskContext.stop() is invoked.filter
- to validate which entries should be feed into the task. Might be null.task
- callback to be invoked in parallel for each stored entry that passes the filter checkexecutor
- an external thread pool to be used for parallel iterationfetchValue
- whether or not to fetch the value from the persistent store. E.g. if the iteration is
intended only over the key set, no point fetching the values from the persistent store as
wellfetchMetadata
- whether or not to fetch the metadata from the persistent store. E.g. if the iteration is
intended only ove the key set, then no pint fetching the metadata from the persistent store
as wellPersistenceException
- in case of an error, e.g. communicating with the external storageint size()
PersistenceException
- in case of an error, e.g. communicating with the external storageCopyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.