如何计算 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

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