kk
-
Flink 源码阅读准备之 – Java8 异步编程
阅读 Flink 源码前必会的知识 Java8 异步编程 本文大纲速看 一、异步编程 通常来说,程序都是顺序执行,同一时刻只会发生一件事情。如果一个函数依赖于另一个函数的结果,它只…
-
Flink 源码阅读准备之 – SPI 和 ClassLoader
一、本文大纲 二、ClassLoader 类加载器 1、Java 中的类加载器以及双亲委派机制 Java 中的类加载器,是 Java 运行时环境的一部分,负责动态加载 Java 类…
-
Flink metrics 介绍和应用
一、Flink metrics简介 Flink 的 metrics 是 Flink 公开的一个度量系统,metrics 也可以暴露给外部系统,通过在 Flink 配置文件 conf…
-
Flink 异步 I/O 解析
一、简介 我们知道 flink 对于外部数据源的操作可以通过自带的连接器,或者自定义 sink 和 source 实现数据的交互。 那么为啥还需要异步 IO 呢?那时因为对于实时处…
-
Flink 用户代码如何生成 StreamGraph(下)
九、一小段源码 上次说到了所有的算子都会转化成 transformation ,并放到一个 List 列表中,那么今天我们开始遍历这个列表,来生成 StreamGraph。 打开这…
-
Flink 用户代码如何生成 StreamGraph (1)
Flink 是如何将你写的代码生成 StreamGraph 的(1) 一、絮叨两句 新的一年又来了,不知道大家有没有立几个每年都完不成的 FLAG ? 反正我立了,我今年给自己立的…
-
Flink Sql 核心概念剖析
本次,我们从 0 开始逐步剖析 Flink SQL 的来龙去脉以及核心概念,并附带完整的示例程序,希望对大家有帮助! 本文大纲 一、快速体验 Flink SQL 为了快速搭建环境体…
-
Flink-Clients 源码阅读(2)
一、我们本次的目的是什么? 这次我们的目的是,在本地的 IDEA 中去 debug flink-clients 代码,然后远程提交给 flink standalone 集群上去执行…
-
Flink-Clients 模块源码阅读
本文大纲 一、Flink 官方文档这么全面,为什么还要读 Flink 源码 读文档和读源码的目的是不一样的,就拿 Apache Flink 这个项目来说,如果你想知道 Flink …
-
红楼梦 第24回
标题:醉金刚轻财尚义侠 痴女儿遗帕惹相思 这一回主要是贾芸的出场,他主要是想和贾琏凤姐儿谋求一个在大观园干活的职位,为了巴结凤姐买麝香而被自己的舅舅无情嘲笑。后半段认识了小红丫头的…