Fwd: Executor inbound buffer queue(receive) and sender buffer queue when use collector.emit(streamId,tupleValues)
Hello! I would like to know how Storm manages the internal buffer queues when using the collector.emit(streamId,ValusToEmit)? For example considering the topology 1. Spout->ProcessingBolt 2. spout.collector.emit(streamId1, tupleValues1) spout.collector.emit(streamId2, tupleValues2) Q. How the buffer send queue look for Spout? Q. How the receive buffer queue look like for ProcessingBolt? Q. Does it use internally a Map ( queue per each stream) or a single LMAXQueue that handles the input/outputs for all the streams? I look forward for your answers. Regards, Florin
Executor inbound buffer queue(receive) and sender buffer queue when use collector.emit(streamId,tupleValues)
Hello! I would like to know how Storm manages the internal buffer queues when using the collector.emit(streamId,ValusToEmit)? For example considering the topology 1. Spout->ProcessingBolt 2. spout.collector.emit(streamId1, tupleValues1) spout.collector.emit(streamId2, tupleValues2) Q. How the buffer send queue look for Spout? Q. How the receive buffer queue look like for ProcessingBolt? Q. Does it use internally a Map ( queue per each stream) or a single LMAXQueue that handles the input/outputs for all the streams? I look forward for your answers. Regards, Florin