
突然想到一些東西颊乘,隨便記記吧耿焊。之前聽到一首歌兆衅,翻來覆去的唱下面幾句。"春有百花秋有月,夏有涼風冬有雪。若無閑事掛心頭,便是人間好時節(jié)慰枕。"這原是佛...
spark(spark-2.10)算子(如map、filter等)的源碼實現(xiàn)即纲,都會調(diào)用ClosureCleaner.clean對傳入的funct...
類似簡單的wordcount具帮,MapReduce輸出的統(tǒng)計結果卻不符預期。部分key丟失了低斋,未丟失的key蜂厅,其value值也不對。經(jīng)查膊畴,是因為代...
withSpout在spark中是用來做DAG可視化的掘猿,它在代碼里的用法如下(以map為例,spark 1.5.0版本) 因為對scala語法比...
在實際工作中唇跨,會將avro文件讀到一個類中稠通。下面就看看代碼是如何實現(xiàn)的(這里看的是avro-1.7.7版本)。 讀取整個avro文件的類是Dat...
avro文件結構 avro文件格式大致如下(引用自avro官網(wǎng)Specification的Object Container Files一節(jié)) A...
這篇文章說是對AbstractQueuedSynchronizer源碼的閱讀买猖,倒不如說是對java interrupt的理解改橘。 在看await(...
AbstractQueuedSynchronizer為鎖機制維護了一個隊列,需要獲取鎖的線程們排在隊列中玉控,只有排在隊首的線程才有資格獲取鎖飞主。Co...
本文為后續(xù)介紹AbstractQueuedSynchronizer.ConditionObject做一下鋪墊。 Lock&Condition L...