6.1.8 윈도 연산으로 일정 시간 동안 유입된 데이터만 계산
예제 애플리케이션으로 다시 되돌아가자. 마지막 업무는 지난 1시간 동안 거래량이 가장 많았던 유가 증권 1~5위를 찾는 것이다. 이 지표는 일정 시간 내의 데이터만 대상으로 계산해야 하기 때문에 앞서 계산한 지표와는 다른 유형의 연산이 필요하다. 스파크 스트리밍에서는 윈도 연산(window operation)을 사용해 구현할 수 있다.
예제 애플리케이션으로 다시 되돌아가자. 마지막 업무는 지난 1시간 동안 거래량이 가장 많았던 유가 증권 1~5위를 찾는 것이다. 이 지표는 일정 시간 내의 데이터만 대상으로 계산해야 하기 때문에 앞서 계산한 지표와는 다른 유형의 연산이 필요하다. 스파크 스트리밍에서는 윈도 연산(window operation)을 사용해 구현할 수 있다.