Датчики нерегулярно выдают данные об уровне шума; вам необходимо вычислить среднее значение для датчика, когда непрерывные данные поступают более 30 минут, но завершить окно после 15 минут бездействия. Какое оконное агрегирование вы используете?

Сессионные окна (session windows) идеально подходят для обработки нерегулярных данных, так как они группируют элементы, поступающие близко друг к другу по времени, и закрываются после определенного периода бездействия. В данном случае, "продолжительность пропуска" (gap duration) в 15 минут означает, что окно будет закрыто, если в течение 15 минут не поступают новые данные. Это соответствует требованию завершить окно после 15 минут бездействия. Непрерывные данные в течение 30 минут будут агрегироваться в одно окно, пока не наступит 15-минутный перерыв. Неправильные варианты: Сессионные окна с продолжительностью пропуска в 30 минут: это закроет окно только после 30 минут бездействия, что не соответствует требованию в 15 минут. Скользящие окна (hopping windows) и непересекающиеся окна (tumbling windows): эти типы окон имеют фиксированный размер и/или интервал, что не подходит для нерегулярных данных, где начало и конец окна зависят от активности данных, а не от предопределенного расписания.