测量 Storm 螺栓的延迟

Question

我正在尝试测量拓扑中每个螺栓的延迟。 Storm 给出的延迟数字是不够的，因为我们要计算百分位数。在我当前的设置中，我通过测量完成执行方法（包括调用发射）所需的时间来测量螺栓的延迟。上述方法的假设是，即使当前bolt实例和拓扑中的下一个bolt实例共享同一个executor，collector的emit也会立即返回，而不调用下一个bolt实例的execute方法。

Answer 1

将计时器放在执行方法的开头和结尾（在发出之后）应该没问题。