Pub/Sub에서 Dataflow로 주식 시세를 스트리밍할 때 5초마다 지난 30초의 이동 평균을 계산해야 합니다. 윈도우와 트리거는 어떻게 구성해야 할까요?

주어진 요구사항은 5초마다 지난 30초의 이동 평균을 계산하는 것입니다. 이는 슬라이딩 윈도우(Sliding Window)의 전형적인 사용 사례입니다. 윈도우의 지속 시간(duration)은 평균을 계산할 데이터의 범위인 30초가 되어야 하고, 윈도우가 이동하는 주기(period)는 결과를 내보낼 간격인 5초가 되어야 합니다. AfterWatermark.pastEndOfWindow() 트리거는 워터마크가 윈도우의 끝을 지나면 결과를 한 번만 내보내므로, 각 윈도우에 대해 정확하고 중복 없는 최종 결과를 얻을 수 있습니다. 다른 옵션들은 다음과 같은 이유로 적절하지 않습니다: 5초 고정 윈도우는 30초 데이터를 포함하지 못하며, plusDelayOf(Duration.standardSeconds(30))는 트리거 지연이 너무 깁니다. 30초 고정 윈도우는 5초마다 결과를 내보낼 수 없습니다. 지속 시간 5초의 슬라이딩 윈도우는 30초 데이터를 포함하지 못합니다.