ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Naveen <naveen.band...@gmail.com>
Subject Re: Usage of DataStreamer for bulk loading
Date Mon, 12 Mar 2018 08:55:28 GMT
Hi Gaurav

Decoupling file reading and cache streaming requires kind of a messaging
layer in between right. Initially I was thinking since its a bulk activity
we will be doing, I did not want to have additional memory and system
resources consumed by the introduction of messaging layer. 

But the whole purpose of using DataStreamer for bulk loading is violated, I
may have go for it.

If my understanding is correct, are we trying to implement the below

1. Read in batches, for a collection object, lets say for every 10K records
2. Publish collection object to Solace (Messaging)
3. Consume the collection object from Solace Queue and use DatStreamer <Map
entry> to load it to cache.

OR through StreamRecivers and DataStreamers we can avoid messaging layer for
decoupling the read part with cache streaming part.

If you have any code snippet which does the same, would you be able to share
the code.


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

View raw message