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