| 항목 | 값 |
| 화면 이름 | Aggregate over window |
| 식별자 | aggregateOverWindowV2 |
| 지원 실행 방식 | Streaming |
| 범주 | 집계 (Aggregate) |
윈도 안의 데이터에 집계 표현식을 적용하고 지정한 트리거에 따라 결과를 출력합니다.
| 이름 | 지정 여부 | 자료형 | 의미와 조건 |
Aggregate expressions | 필수 | List<Expression<AnyType>> | 각 윈도에서 평가할 집계 표현식 목록입니다. |
Dataset | 필수 | Table | 집계를 수행할 데이터셋입니다. |
Window | 필수 | Window | 원소를 어떻게 묶을지 정의하는 윈도입니다. |
Accumulation mode | 선택 | Enum<Accumulating, Discarding> | 트리거가 발동했을 때 윈도가 모은 데이터 묶음(pane)을 다음 집계에도 누적할지 폐기할지 정하는 모드입니다. |
Key by columns | 선택 | Set<Column<Binary | Boolean | Byte | Double | Float | Integer | Long | Short | String | Timestamp>> | 키별로 입력을 분할할 열입니다. 고유 키마다 별도로 집계합니다. |
Trigger | 선택 | Trigger | 집계 시점을 정하는 트리거입니다. |