Как рассчитать сетевую задержку между операторами в Apache Apex
Есть ли способ, с помощью которого мы можем предсказать задержку N/W между двумя различными операторами в Apache Apex.
В ситуации, когда данные, которые будут использоваться оператором, находятся на другом компьютере; это добавит к задержке оператора.
Как это можно рассчитать?
2 ответа
Вы можете посмотреть пару статей в блоге:
https://www.datatorrent.com/blog/latency-calculation-in-apache-apex/ https://www.datatorrent.com/blog/blog-apex-performance-benchmark/
Предполагая, что ваши кортежи являются строками и что часы на узлах кластера синхронизированы, вы можете добавить временную метку к каждому кортежу в операторе отправки. Затем в операторе получения вы можете удалить временную метку и сравнить ее с текущим временем. Конечно, вы можете соответствующим образом адаптировать этот подход для других типов. Если усреднить по достаточно большому количеству кортежей, это должно дать вам хорошее приближение задержки сети.