As Alexey said, DataStreamer is for loading data *to* Ignite. So, If you want to get data *from *Ignite, you may choose to use IgniteCache#iterator() <https://static.javadoc.io/javax.cache/cache-api/1.0.0/javax/cache/Cache.html#iterator()> method. But note, that this method is not transactional, so concurrent updates may spoil the results. Another option is to use continuous query <https://apacheignite.readme.io/docs/continuous-queries> with initial query configured, if you also want to process further updates.
There is also IgniteCache#getAll(...) <https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/IgniteCache.html#getAll(java.util.Set)> method, which is transactional, but you should explicitly provide a key set to it. Denis ср, 22 нояб. 2017 г. в 11:54, Alexey Kukushkin <[email protected]>: > Hi, > > You must use IgniteDataStreamer#addData(key, value) to stream data into > Ignite. > > What you did when you attached a receiver would make the data streamer > execute the receiver on the nodes in co-located mode (that is the receiver > logic will be called on the node where the receiver's input data is > located). But to have the receiver logic called you must stream the data > using addData. >
