JavaScript is required

Đáp án nào không phải là một "Transformation" khi thao tác với DStream:

A.
reduceByWindow
B.
window
C.
foreachWindow
D.
countByWindow
Trả lời:

Đáp án đúng: D


Trong Spark Streaming, các transformation là các phép toán được áp dụng trên DStream để tạo ra một DStream mới. Các transformation thường gặp bao gồm `map`, `filter`, `reduceByKey`, `window`, `reduceByWindow`, `countByWindow`,... * `reduceByWindow`: Là một transformation, kết hợp các giá trị trong một cửa sổ trượt bằng cách sử dụng một hàm reduce. * `window`: Là một transformation, tạo ra một DStream mới bằng cách áp dụng một cửa sổ trượt trên DStream gốc. * `countByWindow`: Là một transformation, trả về số lượng phần tử trong mỗi cửa sổ. * `foreachWindow`: Không phải là transformation. Thay vào đó, nó là một output operation (hoạt động xuất dữ liệu) cho phép bạn thực hiện một hành động trên mỗi RDD trong một cửa sổ thời gian. Nó được sử dụng để đẩy dữ liệu ra bên ngoài Spark Streaming. Vậy đáp án C là đáp án đúng nhất vì nó không phải là transformation mà là một output operation.

Câu hỏi liên quan