Hello!
I have a case study where the same message (identified by an id) is
spread over a couple of processing bolts and a final bolt should act as a
barrier. This final bolt should do its job on the message ID only when all
the upfront bolts have finished their process on the message.
As sketch is bellow
Spout -> (msgid1, payload)->process bolt 1 (msgId1, payloadb1) |
->process bolt 2(msgId1,
payloadb2) |->final bolt(msg1,finalp)
->process bolt 3(msgId1,
payloadb3) |
So the final bolt should not start a work on a message id till the message
was not processed by all the 3 processing bolts.
My question are:
1. Can be these case viable for storm?
2. If the answer for the first question is yes, how can I achieve this
request?
3. Is possible to achieve this request without using trident?
I look forward for your answers.
Thanks,
Florin
