第一章 初識(shí)Flink 大數(shù)據(jù)開(kāi)發(fā)總體架構(gòu) 數(shù)據(jù)傳輸層:常用的數(shù)據(jù)傳輸工具有Flume、Sqoop、Kafka。Flume是一個(gè)日志收集系統(tǒng),用于將大量日志數(shù)據(jù)從不同的源進(jìn)行...
第一章 初識(shí)Flink 大數(shù)據(jù)開(kāi)發(fā)總體架構(gòu) 數(shù)據(jù)傳輸層:常用的數(shù)據(jù)傳輸工具有Flume、Sqoop、Kafka。Flume是一個(gè)日志收集系統(tǒng),用于將大量日志數(shù)據(jù)從不同的源進(jìn)行...
前言 上文簡(jiǎn)單介紹了響應(yīng)式編程和Reactor的使用,今天開(kāi)始深入了解一下響應(yīng)式編程的規(guī)范,為開(kāi)始學(xué)習(xí)Reactor源碼做準(zhǔn)備 Reactive streams 上文也簡(jiǎn)單提...
前言 熟悉 Java 并發(fā)包的人一定對(duì) LockSupport 的 park/unpark 方法不會(huì)感到陌生,它是 Lock(AQS)的基石,給 Lock(AQS)提供了掛起...