apache-apex - 如何计算 Apache Apex 中运营商之间的网络延迟

Question

有没有一种方法，我们可以使用它来预测 Apache Apex 中两个不同运算符之间的 N/W 延迟。

在将要在操作员中使用的数据完全驻留在不同机器上的情况下；这将增加操作员的延迟。

这个怎么计算？

Answer 1

您可能想查看几篇博客文章：

https://www.datatorrent.com/blog/latency-calculation-in-apache-apex/ https://www.datatorrent.com/blog/blog-apex-performance-benchmark/

Answer 2

假设您的元组是字符串并且集群节点上的时钟是同步的，您可以在发送操作符中为每个元组附加一个时间戳。然后，在接收运算符中，您可以剥离时间戳并将其与当前时间进行比较。当然，您可以适当地将这种方法适用于其他类型。如果对适当数量的元组进行平均，它应该为您提供网络延迟的良好近似值。