Re: loadAll and removeAll from cache with custom store

2017-12-22 Thread slava.koptilin
Hi Matt, I've tried the following code based on your configuration and it works. public static void main(String[] args) throws Exception { Ignite ignite = Ignition.start(createIgniteConfiguration()); IgniteCache cache1 =

Re: loadAll and removeAll from cache with custom store

2017-12-22 Thread matt
Hi, The size in my store is about 9k. I do have loadAll() working now, so once that completes, the cache has 9k items as well. For deleteAll(), I had it work once where it called my adapter multiple times with all of the expected keys. But then restarting my app and trying again (after loading

Re: loadAll and removeAll from cache with custom store

2017-12-22 Thread slava.koptilin
Hi Matt, I think you can use IgniteCache.loadCache() [1] in order to load all key-value pairs into the cache before running any job. > For removeAll, I'm seeing that my cache store adapter only ever gets > called once (deleteAll) but the keys only ever have 1000 keys I've tried this use case and

Re: loadAll and removeAll from cache with custom store

2017-12-21 Thread matt
For the removeAll() call, I do see that after I do a loadCache((k,v) -> true) I can delete items from the store, but my store's deleteAll() only ever gets 1k items once, deletes them from the store, and then is never called again to delete the rest of the items in the store. -- Sent from: