У меня есть работа с потоковым воспроизведением и я хочу написать одну метрику c (тип сердцебиения) в конце интервала пакета. Это может быть достигнуто путем сокращения всего DStream до единого значения, а затем использовать его для записи метри c. Есть ли лучший способ добиться этого?