Hi there, I'm using storm 1.0.1. I have user case like this, given one signal (received from kafka spout), fetch a bunch of users (in mongodb), then do stream processing.
I'd prefer trident since the lambda like language is so convenient. But don't have good idea about iterating through mongodb. By checking storm source code, there's good example for insert and update but not loop. So questions are: 1. Is it a good idea to iterate mongo in storm stream processing? 2. If so, any good idea or example? 3. If not, why? -- Regards, Qili Chen (Cheney) E-mail: [email protected] MP: (+1) 4086217503
