Как рассчитать транзакцию как таковую c (TPS) в apache flink, используя Java

Question

Я читаю из потока kafka с помощью flink, и теперь я хочу рассчитать транзакции как таковые c (TPS). Я наблюдал один из способов добиться этого, используя концепцию окон во flink, но пока не могу этого понять. Может ли кто-нибудь помочь мне в этом. Заранее спасибо за помощь !!.

Answer 1

Есть встроенная метрика c, которая сообщает numRecordsOutPerSecond, что вы можете наблюдать в исходном операторе Kafka (или любом другом операторе). Возможно, это все, что вам нужно:

For a tutorial (and examples) for learning how to use Flink's windowing API, see the введение в windows в учебном курсе Flink, который является частью документации.