
spark 0.2版本與0.1版本相比較,RDD增加了groupBy算子柳弄,并豐富了PariRDD的算子(reduceByKey、combineB...
Spark 0.1是spark開源的第一個版本赊堪,本文主要從組成類、如何觸發(fā)執(zhí)行竖哩、如何具體執(zhí)行這幾個方面進行分析哭廉。 主要組成類: 1.RDD,其中...
ConcurrentHashMap簡介: ConcurrentHashMap是線程安全且高效的HashMap相叁,使用鎖分段技術(shù)提高并發(fā)訪問率遵绰; C...
基本概念: 鎖:控制多線程并發(fā)訪問資源;隊列同步器:管理同步狀態(tài)增淹,實現(xiàn)鎖椿访;同步狀態(tài):同步器的操作對象,int類型虑润;同步隊列:同步器通過同步隊列管...
線程的優(yōu)先級: 線程的優(yōu)先級越高成玫,占用CPU的能力越強; 線程中斷: 調(diào)用線程對象的interrupt()函數(shù)后端辱,線程并不會立即中斷梁剔,而是將線程...
上下文切換: CPU切換線程時就產(chǎn)生了一次上下文切換; Java如何實現(xiàn)原子操作: 鎖和CAS操作舞蔽; happens-before規(guī)則:前一個操...
題目 題目內(nèi)容 實現(xiàn)一個基于發(fā)布/訂閱模型的消息中間件,功能要求如下: broker保證消息落盤后才向producer返回發(fā)送成功的ack码撰,并把...
題目 題目內(nèi)容 Topic類似于水壩(蓄積功能渗柿,消峰填谷之利器),Queue類似于水渠脖岛;每當(dāng)新建一個Queue的時候朵栖,可以選擇綁定到幾個Topi...
1、Schema的定義 通過StructType和StructField等API來定義Schema柴梆。 StructType的構(gòu)造器:new St...