Apache Beam и закрытие окна при выполнении условия ⇐ JAVA

[Anonymous]

В Apache Beam в задании потоковой передачи я могу создать IntervalWindow, который будет длиться 7 дней.

Код: Выделить всё

IntervalWindow interval = new IntervalWindow(timestamp, Duration.standardDays(7));

Но есть ли способ автоматически закрыть окно при выполнении определенного условия, например, когда в окне минимум 4 сообщения? Сразу после этого я хотел бы выполнить некоторую логику и закрыть окно, не дожидаясь истечения 7 дней. Возможно ли это в Apache Beam, и если да, то как?

Подробнее здесь: https://stackoverflow.com/questions/792 ... ion-is-met