> WindowSpec cumSum = Window.partitionBy("srl").rowsBetween(Window.unboundedPreceding(), Window.currentRow());
같은 srl을 기준으로 누적합계를 구해줌
'IT 개발 > Spark 관련' 카테고리의 다른 글
| spark window 함수 관련 (0) | 2021.04.05 |
|---|---|
| Spark 완벽 가이드 (0) | 2020.11.02 |
| 빅데이터 분석을 위한 스파트2 프로그래밍 (0) | 2020.11.01 |