[infinispan-dev] Map/Reduce or other batch processing on CacheLoader stored entries

[Manik Surtani]

#processEntriesWith(Processor p)

Processor extends Lifecycle { // Lifecycle for start() and stop() methods… 
   void process(CacheEntry e);
   void process(Collection<CacheEntry> e);
   boolean processMoreEntries();
}

On 25 May 2012, at 10:51, Tristan Tarrant wrote:

> On 05/25/2012 11:47 AM, Manik Surtani wrote:
>> loadAllInto(Consumer engine);
>> 
>>> Yes, when I said Callable I meant exactly what you wrote.
>> Except in more generic terms.  :)
>> 
>> I suppose you specifically meant loadAll(Callable<CacheEntry>  c) ?
> 
> Yes, but probably "loadAll" is not too appropriate, since "load" implies 
> "retention in memory" (at least in my mind), whereas here we just mean 
> "iterate over the entries and do something with them". Semantics, I 
> know, but good self-explanatory method names go a long way.
> 
> Tristan
> 
> _______________________________________________
> infinispan-dev mailing list
> infinispan-dev at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/infinispan-dev

--
Manik Surtani
manik at jboss.org
twitter.com/maniksurtani

Lead, Infinispan
http://www.infinispan.org