發(fā)簡信
IP屬地：北京
各種大數(shù)據(jù)框架近幾年發(fā)展得如火如荼，比如Hadoop, MapReduce,Hive, Hbase, Storm, Spark, Flink, ...
Flink程序是對數(shù)據(jù)流，進(jìn)行各種分布式處理/轉(zhuǎn)換。通過sources創(chuàng)建輸入的數(shù)據(jù)流(可以讀取文件，從kafka的topic讀取，或者內(nèi)存的c...
Window在流式計(jì)算中很重要，因?yàn)椤绷鳌笔且粋€(gè)無終點(diǎn)的持續(xù)輸入，所以通過window機(jī)制來分塊，進(jìn)行聚合等各種處理 Keyed vs Non-...
Flink支持Exactly-Once級別的準(zhǔn)確行，這是一個(gè)很高的要求，一般的高吞吐量系統(tǒng)只支持At-least-Once級別的。Lightwe...
一 為什么需要State存儲 與批計(jì)算相比，State是流計(jì)算特有的，批計(jì)算的failover機(jī)制，是失敗后重新計(jì)算；流計(jì)算在大多數(shù)場景下是增量...
一 流計(jì)算對“批計(jì)算”的優(yōu)勢： “流計(jì)算”是相對于“批計(jì)算”來的，MapReduce，Spark底層的計(jì)算方式是目前主流的“批計(jì)算”實(shí)現(xiàn)方式...