Как использовать систему метрик или подобные вещи для данных WindowedStream?

Question

Я хотел бы измерить пропускную способность каждого окна в Apache Flink. Метрика не соответствует WindowedStream, поскольку в нем говорится, что он не поддерживает RichFunction в качестве AggregateFunction. Вместо этого я использовал экземпляр Singleton, но кто-то сказал, что это плохо для распределенной среды. (локально работает нормально) Есть ли решения для этой ситуации?

Answer 1

Существуют встроенные показатели, измеряющие

numBytesInLocalPerSecond
numBytesInRemotePerSecond
numBytesOutPerSecond
numRecordsInPerSecond
numRecordsOutPerSecond

Эти показатели пропускной способности доступны для каждого оператора (за исключением входных показателей для источников и выходных показателей для приемников),включая окна.