[GCP] Windowing in Dataflow

Windowing

윈도우 기능은 제한되지 않은 컬렉션을 논리적 구성 요소 또는 windows로 나눕니다 . Windowing 함수는 개별 요소의 타임 스탬프별로 제한되지 않은 컬렉션을 그룹화합니다.

Fixed window

고정 간격의 window로 모든 키에 걸쳐 균일하며 두 개의 연속된 과부 사이에 겹치지 않음

• Use cases : 모든 통합 사용 사례, 데이터의 배치 분석, 비교적 단순한 사용 사례

Sliding window

모든 key에 걸쳐 균일한 고정 간격의 window, 두 창 사이에 겹침이 있음(여러 창에 동일한 요소가 있을 수 있음)

• Use cases : 데이터의 평균이 이동할때

Session window

동적으로 설정된 간격, key 간에 균일하지 않은 창(key마다 다른 창, key마다 다른 창 크기), 두 창 간에 겹치지 않음

• Use cases : user session data, click data, real time gaming data analysis

참고 출처 : https://medium.com/@pavankumarkattamuri/windowing-in-cloud-dataflow-fixed-sliding-session-becda3b12bbd