Re: Deadlock during cache loading

[breischl]

Hi Denis,
  It was not clear to me that we could do the update from within the
StreamReceiver without some sort of cache operation. Would we just use the
CacheEntry.setValue() method to do that? Something roughly like the
following?

Thanks!


public void receive(IgniteCache<TKey, TEntity> cache,
Collection<Map.Entry&lt;TKey, TEntity>> newEntries) throws IgniteException {

        for (val newEntry : newEntries) {
            //Do our custom logic
            newEntry.setValue(someNewValue);
        }
}





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/