更新時間:2021-01-05 來源:黑馬程序員 瀏覽量:
Spark Streaming提供了一個高級抽象的流,即DStream(離散流)。DStream表示連續(xù)的數據流,可以通過Kafka、Flume和Kinesis等數據源創(chuàng)建,也可以通過現(xiàn)有DStream的高級操作來創(chuàng)建。DStream的內部結構如圖1所示。
圖1 DStream流的內部結構
從圖1可以看出,DStream的內部結構是由一系列連續(xù)的RDD組成,每個RDD都是一小段時間分隔開來的數據集。實際上,對DStream的任何操作,最終都會轉變成對底層RDDs的操作。
猜你喜歡:
【AI設計】北京143期畢業(yè)僅36天,全員拿下高薪offer!黑馬AI設計連續(xù)6期100%高薪就業(yè)
2025-09-19【跨境電商運營】深圳跨境電商運營畢業(yè)22個工作日,就業(yè)率91%+,最高薪資達13500元
2025-09-19【AI運維】鄭州運維1期就業(yè)班,畢業(yè)14個工作日,班級93%同學已拿到Offer, 一線均薪資 1W+
2025-09-19【AI鴻蒙開發(fā)】上海校區(qū)AI鴻蒙開發(fā)4期5期,距離畢業(yè)21天,就業(yè)率91%,平均薪資14046元
2025-09-19【AI大模型開發(fā)-Python】畢業(yè)33個工作日,就業(yè)率已達到94.55%,班均薪資20763元
2025-09-19【AI智能應用開發(fā)-Java】畢業(yè)當天offer率91%,薪資1W+占比54.2%,班級均薪12k+
2025-09-19