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