Hi, i need a receiver because i want to increase the value of item if it is stored in cache, like a word-count example. I agree with you about flush.
Thanks, Mimmo Il dom 22 apr 2018, 08:57 begineer <[email protected]> ha scritto: > I dont understand why you need to define receiver to update value in the > cache. streamer does is for you. you just need to write something like this > > try (IgniteDataStreamer<Long, Integer> streamer = > ignite.dataStreamer("cacheName")) { > > for(Entry<Long, Integer> entry : maps.entrySet()){ > stmr.addData(entry.getKey().longValue(),entry.getValue()); > } > } > > datastreamer will flush the data to cache as soon as try with resources is > completed. you don't even need to flush manually > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
