测量风暴螺栓的潜伏期

y3bcpkx1  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(343)

我试图测量拓扑中每个螺栓的延迟。storm给出的延迟数是不够的,因为我们要计算百分位数。在我当前的设置中,我通过测量完成execute方法(包括调用emit)所需的时间来测量bolt的延迟。上述方法的假设是,收集器的emit将立即返回,而不调用next bolt instances execute方法,即使拓扑中的当前bolt示例和下一个bolt示例共享了相同的执行器。

erhoui1w

erhoui1w1#

通过将计时器放在execute方法的开头和结尾(在emit之后),就可以了。

相关问题