發(fā)簡信
IP屬地：天津
-
flink的Snapshot
flink的snapshot的算法在這篇論文面哥，本文講述也是基于這部分內(nèi)容列牺，如果有興趣可以自行參考原文肠鲫。 介紹 目前已知的能夠保證只執(zhí)行一次...
-
flink的內(nèi)存管理在大數(shù)據(jù)面前亥至，JVM的內(nèi)存結(jié)構(gòu)和GC機(jī)制往往會(huì)成為掣肘 1. 對(duì)象開銷：在HotSpot中，每個(gè)對(duì)象占用的內(nèi)存空間必須是8的倍數(shù)。這就導(dǎo)致每個(gè)對(duì)...
-
flink-example
在我的git偿荷，:) -_-||
-
flink的執(zhí)行計(jì)劃——StreamGraph
flink的執(zhí)行計(jì)劃分為四層： 通過Stream API提交的文件，首先會(huì)被翻譯成StreamGraph况芒。StreamGraph的生成的邏輯是在...
-
flink client/JobManager/TaskManager的啟動(dòng)這里只介紹Standalone模式 Client flink官方支持多種模式standalone/yarn/mesos flink在啟動(dòng)的時(shí)候惜纸，...
-
[zz]Functor, Applicative, 以及 Monad 的圖片闡釋這是個(gè)簡單的值: 我們都知道怎么加一個(gè)函數(shù)應(yīng)用到這個(gè)值上邊: 很簡單了. 我們來擴(kuò)展一下, 讓任意的值是在一個(gè)上下文當(dāng)中. 現(xiàn)在的情況你可以想象...
-
Storm Nimbus的HAStorm在1.0之后對(duì)nimbus支持了HA，根據(jù)官方提供的文檔绝骚，同樣是利用了zk來做分布式鎖耐版，并且配置文件中新增了storm.seeds，而...
-
Storm LinearDrpc以ReachTopology為例子压汪，這個(gè)類在storm-starter里粪牲。 LinearDRPC顧名思義是線性的，bolt的處理流程是linea...