Издает ли Apache Beam какой-либо показатель количества отброшенных (поздних) сообщений?
Будь то DirectRunner или DataflowRunner.Спасибо!
DirectRunner
DataflowRunner
Похоже, что существует метрика droppedDueToClosedWindow при запуске конвейера в облачном потоке данных.
droppedDueToClosedWindow