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<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/