Kafka Direct 跟Receiver方式的區(qū)別 Receiver Receiver是使用Kafka的 High-Level Consumer API來(lái)實(shí)現(xiàn)的。Rece...
IP屬地：浙江
-
Spark 連接kafka兩種方式及區(qū)別(direct和receiver) -
Hadoop - HDFSHDFS 分布式文件系統(tǒng) Hadoop -YARNHadoop -MapReduce 導(dǎo)讀1.HDFS是什么2.HDFS架構(gòu)及組件功能介紹3.讀寫(xiě)流程 HDFS是什么 HD...
-
Hadoop - YARNYARN - 資源管理 Hadoop -MapReduceHadoop -HDFS 導(dǎo)讀一. Hadoop 1.x 介紹二. Hadoop 2.x 介紹 - 重點(diǎn)三. yar...
-
Hadoop - MapReduceMapReduce(mr) -- 分布式計(jì)算框架 Hadoop -YARN Hadoop -HDFS 導(dǎo)讀一.MapReduce介紹二.MapReduce工作流程及shu...
-
Flink-1.10 源碼筆記 StreamGraph生成
Flink 1.10 源碼 -- SreamGraph 生成JobGraph Flink的執(zhí)行計(jì)劃分為四層 StreamGraph用戶層面上的, 用戶根據(jù)API編寫(xiě)的程序構(gòu)造...
-
Flink-1.10 源碼筆記 分布式快照Flink源碼- 分布式快照 Flink 分布式快照核心概念之一, Barrier會(huì)被注入數(shù)據(jù)流,作為數(shù)據(jù)流得一部分向下流動(dòng),barrier用于不會(huì)超過(guò)其他數(shù)據(jù),也不會(huì)被其他...