分享程序员的故事，干货，资料。<br>一线大厂面试题、高并发等主流技术资料 ：JSYH1w
IP属地：浙江
-
Spark 连接kafka两种方式及区别(direct和receiver)Kafka Direct 跟Receiver方式的区别 Receiver Receiver是使用Kafka的 High-Level Consumer API来实现的。Rece...
-
Hadoop - HDFSHDFS 分布式文件系统 Hadoop -YARNHadoop -MapReduce 导读1.HDFS是什么2.HDFS架构及组件功能介绍3.读写流程 HDFS是什么 HD...
-
Hadoop - YARNYARN - 资源管理 Hadoop -MapReduceHadoop -HDFS 导读一. Hadoop 1.x 介绍二. Hadoop 2.x 介绍 - 重点三. yar...
-
Hadoop - MapReduceMapReduce(mr) -- 分布式计算框架 Hadoop -YARN Hadoop -HDFS 导读一.MapReduce介绍二.MapReduce工作流程及shu...
-
Flink-1.10 源码笔记 StreamGraph生成
Flink 1.10 源码 -- SreamGraph 生成JobGraph Flink的执行计划分为四层 StreamGraph用户层面上的, 用户根据API编写的程序构造...
-
Flink-1.10 源码笔记 分布式快照Flink源码- 分布式快照 Flink 分布式快照核心概念之一, Barrier会被注入数据流,作为数据流得一部分向下流动,barrier用于不会超过其他数据,也不会被其他...
-
Flink-1.10 源码笔记 checkpint -- 3
Flink 源码笔记 --- checkpoint 接上篇内容 Flink-1.10 源码笔记 checkpint - 2 Snapshot确认消息发送 在AsyncC...
-
Flink-1.10 源码笔记 process && 调用过程
我们知道flink已经封装了很多高级的api供用户访问使用，但是有时候我们可能根据不同的需求，发现提供的高级api不能满足我们的需求，这个时候flink也为我们提供了low-...
-
Flink-1.10 源码笔记 checkpint -- 2
Flink 源码笔记 --- checkpoint 接上篇内容 Flink-1.10 源码笔记 checkpint - 1 进入taskExecutorGateway的...
-
Flink-1.10 源码笔记 checkpint -- 3
Flink 源码笔记 --- checkpoint 接上篇内容 Flink-1.10 源码笔记 checkpint - 2 Snapshot确认消息发送 在AsyncC...
-
Flink-1.10 源码笔记 checkpint -- 1
Flink 源码笔记 --- checkpoint 设置触发checkpoint的节点 ExecutionGraph该对象运行在 SchedulerBase中, Sched...
-
Flink-1.10 源码笔记 process && 调用过程
我们知道flink已经封装了很多高级的api供用户访问使用，但是有时候我们可能根据不同的需求，发现提供的高级api不能满足我们的需求，这个时候flink也为我们提供了low-...
