四虎国产精品永久地址998_chinesexxx少妇露脸_日本丁香久久综合国产精品_一区二区久久久久_四虎av影视_久久久久国产一区二区三区不卡

中培偉業IT資訊頻道
您現在的位置:首頁 > IT資訊 > 大數據 > 【專家視點】詳解Spark架構的性能與應用

【專家視點】詳解Spark架構的性能與應用

2017-01-20 11:47:59 | 來源:中培企業IT培訓網

Spark作為UC Berkeley AMP lab所開源的類Hadoop MapReduce的通用的并行計算框架,其基于map reduce算法實現的分布式計算,有Hadoop MapReduce所具有的優點;但不同于MapReduce的是Job中間輸出和結果可以保存在內存中,從而不再需要讀寫HDFS,因此Spark能更好地適用于數據挖掘與機器學習等需要迭代的map reduce的算法。其架構如下圖所示:spark-framwork

Spark與Hadoop的比較

Spark的中間數據放到內存中,對于迭代運算效率更高。 ?Spark更適合于迭代運算比較多的MLDM運算。因為在Spark里面,有RDD的抽象概念。 

SparkHadoop更通用。 ?Spark提供的數據集操作類型有很多種,不像Hadoop只提供了MapReduce兩種操作。比如map, filter, flatMap, sample, groupByKey, reduceByKey, union, join, cogroup, mapValues, sort,partionBy等多種操作類型,Spark把這些操作稱為Transformations。同時還提供Count, collect, reduce, lookup, save等多種actions操作。

這些多種多樣的數據集操作類型,給給開發上層應用的用戶提供了方便。各個處理節點之間的通信模型不再像Hadoop那樣就是唯一的Data Shuffle一種模式。用戶可以命名,物化,控制中間結果的存儲、分區等。可以說編程模型比Hadoop更靈活。 

不過由于RDD的特性,Spark不適用那種異步細粒度更新狀態的應用,例如web服務的存儲或者是增量的web爬蟲和索引。就是對于那種增量修改的應用模型不適合。 

容錯性。 在分布式數據集計算時通過checkpoint來實現容錯,而checkpoint有兩種方式,一個是checkpoint data,一個是logging the updates。用戶可以控制采用哪種方式來實現容錯。

可用性。 ?Spark通過提供豐富的Scala, JavaPython API及交互式Shell來提高可用性。

Spark與Hadoop的結合

Spark可以直接對HDFS進行數據的讀寫,同樣支持Spark on YARNSpark可以與MapReduce運行于同集群中,共享存儲資源與計算,數據倉庫Shark實現上借用Hive,幾乎與Hive完全兼容。

Spark的適用場景

Spark是基于內存的迭代計算框架,適用于需要多次操作特定數據集的應用場合。需要反復操作的次數越多,所需讀取的數據量越大,受益越大,數據量小但是計算密集度較大的場合,受益就相對較小

由于RDD的特性,Spark不適用那種異步細粒度更新狀態的應用,例如web服務的存儲或者是增量的web爬蟲和索引。就是對于那種增量修改的應用模型不適合。 

總之Spark作為一種非常高校的分布式計算系統,其在互聯網行業當中擁有十分廣泛和通用的應用前景。

標簽: Spark
主站蜘蛛池模板: 巧家县| 封开县| 鄂托克旗| 南江县| 金阳县| 玉山县| 西充县| 昭平县| 盐源县| 钟山县| 香河县| 合江县| 和龙市| 安溪县| 元朗区| 文山县| 衡山县| 扎兰屯市| 丰城市| 成都市| 卫辉市| 天柱县| 惠来县| 元阳县| 镇安县| 鄂托克旗| 武强县| 龙山县| 吉林省| 武清区| 甘泉县| 婺源县| 涪陵区| 八宿县| 江城| 阜新市| 浑源县| 彰化县| 仙居县| 忻州市| 巴青县|