[源碼解析] Flink的Slot究竟是什麼？(2)
- 2020 年 9 月 4 日
- 筆記
[源码解析] Flink 的slot究竟是什么？(2) 目录 [源码解析] Flink 的slot究竟是什么？(2) 0x00 摘要 0x01 前文回顾 0x02 注册/更新Slot 2.1 TaskExecutor注册成功 2.2 心跳机制更新Slot状态 0x03 生成ExecutionGrap …
Continue Reading
[源碼解析] Flink的Slot究竟是什麼？(1)
- 2020 年 8 月 24 日
- 筆記
[源码解析] Flink的Slot究竟是什么？(1) 目录 [源码解析] Flink的Slot究竟是什么？(1) 0x00 摘要 0x01 概述 & 问题 1.1 Fllink工作原理 1.2 问题 0x02 示例代码 2.1 示例代码 0x03 从Slot角度看系统划分 3.1 Flink组件 3 …
Continue Reading[源碼解析] 當 Java Stream 遇見 Flink
- 2020 年 8 月 17 日
- 筆記
[源码解析] 当 Java Stream 遇见 Flink 目录 [源码解析] 当 Java Stream 遇见 Flink 0x00 摘要 0x01 领域 1.1 Flink 1.2 Java Stream 1.3 探寻角度 0x02 数据流模型 2.1 Java Stream 2.2 Flink …
Continue Reading
[源碼解析] Flink UDAF 背後做了什麼
- 2020 年 8 月 12 日
- 筆記
[源码解析] Flink UDAF 背后做了什么 目录 [源码解析] Flink UDAF 背后做了什么 0x00 摘要 0x01 概念 1.1 概念 1.2 疑问 1.3 UDAF示例代码 0x02 批处理 2.1 代码 2.2 计划生成 2.3 执行 2.4 状态管理 2.5 总结 0x03 流 …
Continue Reading
Alink漫談(十四) ：多層感知機 之 總體架構
- 2020 年 7 月 26 日
- 筆記
Alink漫谈(十四) ：多层感知机 之 总体架构 目录 Alink漫谈(十四) ：多层感知机 之 总体架构 0x00 摘要 0x01 背景概念 1.1 前馈神经网络 1.2 反向传播 1.3 代价函数 1.4 优化过程 1.4.1 迭代法 1.4.2 梯度下降 1.5 相关公式 1.5.1 加权求 …
Continue Reading
Alink漫談(十三) ：在線學習演算法FTRL 之 具體實現
- 2020 年 7 月 22 日
- 筆記
Alink漫谈(十三) ：在线学习算法FTRL 之 具体实现 目录 Alink漫谈(十三) ：在线学习算法FTRL 之 具体实现 0x00 摘要 0x01 回顾 0x02 在线训练 2.1 预置模型 2.1.1 训练模型 2.1.2 加载模型 2.2 分割高维向量 2.3 迭代训练 2.3.1 Fl …
Continue Reading[源碼解析] 從TimeoutException看Flink的心跳機制
- 2020 年 6 月 23 日
- 筆記
[源码解析] 从TimeoutException看Flink的心跳机制 目录 [源码解析] 从TimeoutException看Flink的心跳机制 0x00 摘要 0x01 缘由 0x02 背景概念 2.1 四大模块 2.2 Akka 2.3 RPC机制 2.3.1 RpcEndpoint：RPC …
Continue Reading[源碼解析] GroupReduce，GroupCombine 和 Flink SQL group by
- 2020 年 6 月 16 日
- 筆記
[源码解析] GroupReduce，GroupCombine和Flink SQL group by 目录 [源码解析] GroupReduce，GroupCombine和Flink SQL group by 0x00 摘要 0x01 缘由 0x02 概念 2.1 GroupReduce 2.2 G …
Continue Reading