6.1.4 이산 스트림 사용
DStream 객체를 생성했다면 이제 이 객체로 초당 거래 주문 건수를 계산해야 한다. DStream을 어떻게 사용하면 될까?
RDD와 마찬가지로 DStream은 이산 스트림을 다른 DStream으로 변환하는 다양한 메서드를 제공한다. 이 메서드들을 사용해 DStream의 RDD 데이터에 필터링, 매핑, 리듀스 연산을 적용할 수 있으며, DStream 데이터를 다른 DStream과 결합하거나 조인할 수도 있다.
DStream 객체를 생성했다면 이제 이 객체로 초당 거래 주문 건수를 계산해야 한다. DStream을 어떻게 사용하면 될까?
RDD와 마찬가지로 DStream은 이산 스트림을 다른 DStream으로 변환하는 다양한 메서드를 제공한다. 이 메서드들을 사용해 DStream의 RDD 데이터에 필터링, 매핑, 리듀스 연산을 적용할 수 있으며, DStream 데이터를 다른 DStream과 결합하거나 조인할 수도 있다.