添加客服微信详细咨询

购买课程后还有增值服务：

• 大咖交流群（涛哥群内亲自答疑）
• 课程配套文档
• 课程配套代码

001.flink源码工程拉取和本地编译打包.ev4a
002.flink本地运行调试-配置启动jobmanager.ev4a
003.flink本地运行调试-配置启动taskmanager.ev4a
004.flink本地运行调试-通过CliFrontend提交job到集群.ev4a
005.必备基础铺垫-CompletableFuture基本使用.ev4a
006.必备基础铺垫-CompletableFuture有无Async的方法的区别.ev4a
007.必备基础铺垫-CompletableFuture各类stage组合api演示.ev4a
008.必备基础铺垫-CompletableFuture对异常处理的api演示.ev4a
009.必备基础铺垫-CompletableFuture的thenCompose和thenApply区别.ev4a
010.必备基础铺垫-自定义线程池来理解基本原理.ev4a
011.必备基础铺垫-juc中各种开箱即用的线程池.ev4a
012.必备基础铺垫-forkJoinPool的使用示例.ev4a
013.必备基础铺垫-rpc-前言.ev4a
014.必备基础铺垫-rpc-基础版开发.ev4a
015.必备基础铺垫-rpc-进阶版开发（1) .ev4a
016.必备基础铺垫-rpc进阶版开发(2) .ev4a
017.必备基础铺垫-akka概念.ev4a
018.必备基础铺垫-akka基本使用示例.ev4a
019.必备基础铺垫-akka远程通信.ev4a
020.必备基础铺垫-基于akka的rpc调用实现.ev4a
021.flink-rpc框架研习-手写框架-相关说明.ev4a
022.flink-rpc框架研习-手写框架-框架使用效果演示.ev4a
023.flink-rpc框架研习-手写框架-rpcservice的创建工具开发.ev4a
024.flink-rpc框架研习-手写框架-RpcActor开发.ev4a
025.flink-rpc框架研习-手写框架-RpcService获取自身代理的方法开发.ev4a
026.flink-rpc框架研习-手写框架-RpcService获取远程代理的方法开发.ev4a
027.flink-rpc框架研习-手写框架-整体联调测试.ev4a
028.利用rpc框架开发上层模块的心跳功能.ev4a
029.返回completableFuture的方法的rpc调用如何解决.ev4a
030.endpoint内部的线程安全问题整体设计.ev4a
031.异步任务安全架构迭代改造.ev4a
032.心跳服务改成在MainThreadExecutor中调度.ev4a
033.源码学习前言.ev4a
034.stream api源码走读1-socketTextStream().ev4a
035.stream api源码走读2-map和flatmap.ev4a
036.stream api源码走读3-keyBy.ev4a
037.stream api源码走读4-window和sum.ev4a
038.stream api源码走读5-print走读及api最后生成的结果观察.ev4a
039.stream api源码走读6-整体流程回顾.ev4a
040.stream api核心概念梳理总结.ev4a
041.stream api中的operator继承体系补充.ev4a
042.自定义Operator和OperatorCoordinator二开实战案例需求.ev4a
043.stream api源码综合案例实战-expression operator开发.ev4a
044.Stream api源码综合案例实战-expression coordinator开发（1) .ev4a
045.stream api源码综合实战-express coordinator测试准备.ev4a
046.stream api源码综合实战-coordinator测试.ev4a
047.stream api源码综合实战-coordinator开发（2）注册、阻塞功能.ev4a
048.stream api源码综合实战-calculator算子开发.ev4a
049.stream api源码综合实战-阻塞bug问题修复及测试.ev4a
050.stream api源码综合实战-calculator算子实现动态表达式计算.ev4a
051.StreamOperator系统化源码解析-概述.ev4a
052.StreamOperator顶层接口源码走读.ev4a
053.streamOperator类继承体系概述.ev4a
054.AbstractStreamOperator核心方法解析.ev4a
055.AbstractUdfStreamOperator核心方法解析.ev4a
056.算子的setup调用链条分析.ev4a
057.算子的initializeState和Open方法调用链条.ev4a
058.算子的processElement方法调用链条分析.ev4a
059.算子实现类解析示例(streamMap，StreamFilter，CoStreamMap) .ev4a
060.WindowOperator算子的生成流程和整体结构.ev4a
061.windowOperator的processElement方法逻辑透析（ 1) .ev4a
062.windowOperator的processElement方法逻辑透析（2) .ev4a
063.windowOperator的processElement源码细节补充.ev4a
064.MergingWindowAssigner的窗口合并核心逻辑.ev4a
065.MerginWindowAssigner的核心逻辑源码分析.ev4a
066.老架构source所存在的问题.ev4a
067.新架构source的核心设计要点.ev4a
068.新架构source的新增组件及整体工作机制.ev4a
069.新架构source简易实现-关键接口通揽.ev4a
070.简易实现新架构source-1-Source工厂抽象方法解释.ev4a
071.简易实现新架构source-2-Source工厂各方法实现.ev4a
072.简易实现新架构source-3-Enumerator实现.ev4a
073.简易实现新架构source-4-SourceReader实现.ev4a
074.简易实现新架构source-5-其他接口实现.ev4a
075.简易实现新架构source-6-联调测试.ev4a
076.kafkasource源码分析整体介绍.ev4a
077.kafkaSourceEnumerator分配split的流程-1-创建和启动流程.ev4a
078.kafkasourceEnumerator分配split的流程-2-start方法.ev4a
079.kafkasourceEnumerator分配split的流程-3-发现分区变化.ev4a
080.kafkasourceEnumerator分配split的流程-4-分配算法及发送分配事件.ev4a
081.kafkasourceEnumerator分配split的流程-5-流程核心步骤总结.ev4a
082.sourceReader读取-SourceOperator创建Sourcereader并初始化.ev4a
083.sourceReader读取数据流程-2-sourceOpeator驱动sourceReader读数据的入口.ev4a
084.sourceReader读取数据流程-3-从队列取数据并迭代输出.ev4a
085.splitFetcher读数据所需的各类组件构造流程.ev4a
086.splitFetcher读数据的端到端流程.ev4a
087.kafkasource的watermark生成合并机制整体流程.ev4a
088.mainOutput和SplitLocaloutputs介绍-1.ev4a
089.mainOutput和SplitLocaloutputs介绍-2.ev4a
090.输出数据时对splitOutput进行watermark值更新的流程.ev4a
091.周期性触发时对各分片watermark状态的管理流程.ev4a
092.周期性触发时合并watermark的生成及输出流程.ev4a
093.watermark对齐机制的整体流程.ev4a
094.watermark对齐机制中的算子级别对齐和split级别对齐流程.ev4a
095.执行计划之StreamGraph-api与transformation的构造流程解析.ev4a
096.执行计划之StreamGraph-streamGraph的构造和初始化配置.ev4a
097.执行计划之StreamGraph-物理transformation生成StreamNode和Edge的源码流程.ev4a
098.执行计划之StreamGraph-虚拟transformation的转换处理及最终的streamGraph结构分析.ev4a
099.执行计划之JobGraph-jobgraph与streamGraph的主要区别.ev4a
100.执行计划之JobGraph-JobGraph中的重点数据结构类.ev4a
101.执行计划之JobGraph-JobGraph生成过程的整体流程及主要步骤.ev4a
102.执行计划之JobGraph-JobGraph生成过程中的Operator HashID特性及测试.ev4a
103.执行计划之JobGraph-JobGraph生成过程中的chain计算流程.ev4a
104.execution graph 核心概念总述.ev4a
105.execution graph 顺便解惑rescale分区器的迷惑.ev4a
106.execution graph优化重构executionEdge的背景和思想.ev4a
107.execution graph核心数据结构实体类概览.ev4a
108.execution graph案例代码的graph生成结果剖析.ev4a
109.execution graph 生成流程-客户端发送请求流程.ev4a
110.execution graph生成流程-服务端接受job提交请求的流程.ev4a
111.execution graph生成流程-创建jobmaster进而创建scheduler进而调用executionGraph的生成方法
112.execution graph 生成流程-graph实例对象的最终创建流程.ev4a
113.yarn-session集群启动流程分析-启动脚本分析.ev4a
114.在idea里面运行yarnSession客户端提交集群应用到yarn.ev4a
115.FlinkYarnSessionCli提交application到yarn的主流程走读.ev4a
116.flinkYarnSesseionCli创建application并启动am容器的流程.ev4a
117.session集群的jobmanager启动流程分析-入口类分析.ev4a
118.session集群的master启动流程分析-ClusterEntrypoint.runCluster()主流程.ev4a
119.session集群的master启动流程分析-各种服务初始化.ev4a
120.session集群的master启动流程分析-blobserver的创建和启动.ev4a
121.session集群的master启动流程分析-其他service的创建和初始化.ev4a
122.session集群的master启动流程分析-集群组件工厂在各集群模式下的区别.ev4a
123.session集群的master启动流程分析-dispatcherRestEndpoint创建及启动.ev4a
124.session集群的master启动流程分析-dispathcerRestEndpoint补充.ev4a
125.session集群的master启动流程-dispatcherRunner和resourceManagerService的创建流程.ev4a
126.session集群的master启动流程-dispatcher的创建和启动.ev4a
127.session集群的master启动流程-resourcemanager的创建和启动.ev4a
128.session集群下的作业提交方式概述.ev4a
129.session集群下命令行提交job的客户端源码流程.ev4a
130.session集群主节点中负责作业提交请求的rest服务的启动和初始化流程.ev4a
131.命令行和web端提交作业的请求在服务端的接收入口分析.ev4a
132.web方式提交作业后服务端的前置处理流程.ev4a
133.命令行客户端提交作业后服务端的前置处理流程.ev4a
134.dispatcher接收请求并创建jobmaster以及scheduler的过程.ev4a
135,jobmaster利用scheduler进行task部署的流程框架分析.ev4a
136.jobmaster的startScheduling主逻辑回顾.ev4a
137.job调度中的startScheduling()流程（1)–槽位分配.ev4a
138.job调度中的startScheduling()流程(2)-物理资源需求声明流程.ev4a
139.job调度中的startScheduling()流程(3)-物理资源需求声明流程.ev4a
140.job调度中的startJobmasterServices()流程-1-resourcemanager-leader嗅探及注册.ev4a
141.job调度中的startJObMasterService()流程-2-连接resourcemanger提交资源请求.ev4a
142.job调度中的startJobMasterService()-3-向yarn申请容器并启动TaskManager的流程.ev4a
143.yarn-session集群启动流程-承前启后.ev4a
144.yarn-session集群的taskmanager创建和启动.ev4a
145.yarn-session集群的taskexecutor启动及向resourcemanager注册流程.ev4a
146.taskExecutor向RM发送slotReport后在RM端的流程.ev4a
147.RM端向taskExecutor请求槽位后TE端的行为.ev4a
148.TE端内部进行槽位分配及向JobMaster注册及向JM供给槽位的流程.ev4a
149.JobMaster端收到TE发过来的offerSlot()调用后的内部流程分析.ev4a
150.TaskExecutor端收到submitTask()调用后启动Task的流程分析.ev4a
151.task源码分析之-task的构建过程详细解析.ev4a
152.线程task的启动和工作流程分析.ev4a
153.sreamTask的restoreAndInvoke流程-1-StreamTask的init()解析.ev4a
154.streamTask的restoreAndIlnvoke流程-2-StreamTask的restoreGates()流程解析.ev4a
155.steamTask的invoke()流程骨架分析.ev4a
156.streamTask的bufferDeloater()缓存消胀机制分析.ev4a
157.streamTask的invoke()分析-mailboxProcessor类结构分析.ev4a
158.mailboxProcessor中的processMail()分析-Mail的实质及举例.ev4a
159.mailboxProcessor中的processMail()分析-mail获取及运行的完整流程分析.ev4a
160.mailboxProcessor中的runDefaultAction()分析-task的数据处理流程骨架.ev4a
161.task的输入处理-streamTaskNetworklnput的emitNext()方法整体流程.ht
162.task的输入处理-inputgate和resultPartition的概念解析.ht
163.task的输入处理-SinglelnputGate的pollNext()方法主流程.ht
164.task的输入处理-singlelnputGate的pollNext()到Inputchannel的getNextBuffer()全流程.ht
165.task的上下游网络通信之消费端NettyClient创建过程.ht
166.task的上下游网络通信之消费端nettyCilent到生产端nettyServer的netty连接创建过程.ht
167.task上下游网络通信之消费端向生产端发起-分区数据请求.ht
168.task的上下游网络通信之生产端构造nettyServer及启动的过程分析_1 .ht
169.task的上下游网络通信之生产端-nettyserver的核心处理器之PartitionRequestServerHandler_1 .ht
170.task的上下游网络通信之生产端-从subPartition中获取结果数据并发送给消费端的流程_1.ht
171.task输出-算子输出数据的上层api回顾.ht
172.task输出-算子输出流程-channel选择器.ht
173.task输出-算子输出流程-recordWriter序列化StreamRecord并传给ResultPartition.ht
174.task输出-算子输出流程-为subpartition申请内存segment并生成bufferConsumer.ht
175.task输出-算子输出流程-把bufferConsumer添加到sbp的buffers队列.ht
176.flink内存管理-堆内存-堆外内存-直接堆外内存等相关概念铺垫.ht
177.taskmanager内存管理-各区域内存配置参数源码解读.ht
178.taskmanager内存管理-通过flink总内存来推算其他区域内存.ht
179.taskmanager内存管理-通过process总内存来推算-推算逻辑所在的源码.ht
180.taskmanager内存管理-各内存区块的用量统计和用量限制手段.ht
181.taskmanager托管内存管理-rocksdb的内存用量控制机制及测试观察.ht
182.taskmanager托管内存管理-memoryManager对托管内存的分配和预算控制机制.ht
183.taskmanager托管内存管理-rocksdb的内存配置为不占用托管内存预算的测试及解析.ht
184.task的网络内存管理-全局buffer池networkBufferPool和局部buffer池LocalBufferPool基本概念.ht
185.task的网络内存管理-全局buffer池的创建构造及debug观察.ht
186.task的网络内存管理-inputGate创建LocalBufferPool创建时的buffer数参数解析.ht
187.task的网络内存管理-inputGate创建localBufferPool核心构造参数的推算逻辑解析.ht
188.task的网络内存管理-task输入输出数据时向localBufferPool和networkBufferPool申请buffer的逻...
189.task的网络内存管理-补充-ResultPartition创建LocalBufferPool时的核心构造参数推算逻辑.ht
190.task的网络内存管理-补充-InputChannel中管理输入缓存的组件BufferManager初识.ht
191.task的网络内存管理-补充-BufferManager的请求独占buffer和请求浮动buffer功能分析.ht
192.task的网络内存管理-补充-RemotelnputChannel在收到backlog信息时通过BufferManager请求浮...
193.task的网络内存管理-补充-task的恢复过程中读取channel快照数据申请缓存的流程分析.ht
194.task的网络内存管理-补充-从最源头的netty收到数据后到申请网络缓存的全流程分析.ht
195.背压机制的基本概念和整体原理介绍.ht
196.上下游task中用来维护credit信用值的类和变量.ht
197.上下游task的初始信用值互动流程分析.ht
198.上游给下游发数据时不断削减下游信用值的过程以及削减到0后如何停止发数据.ht
199.上游收到下游的AddCredit类型netty消息后在reader中增加信用值并将reader放入可用队列.ht
200.下游task在收到上游的数据时根据backlog请求浮动buffer并向上游反馈新的信用值.ht
201.checkpoint分析-checkpoint整体流程介绍.ht
202.checkpoint分析-checkpointCoordinator的创建及定时调度任务的启动入口.ht
203.checkpoint分析-checkpoint触发请求的选择逻辑.ht
204.checkpoint分析-checkpointCoordinator触发chk的主要步骤.ht
205.checkpoint分析-checkpointPlan的生成.ht
206.checkpoint分析-checkpointlD、checkpoint存储目录等准备工作.ht
207.checkpoint分析-checkpoint存储目录创建过程的debug观察.ht
208.checkpoint分析-触发算子协调器OperatorCoordinator快照的流程.ht
209.checkpoint分析-masterTriggerRestoreHook的checkpoint触发流程.ht
210.checkpoint分析-coordinator端向各subTask发起checkpoint的触发调用.ht
211.checkpoint分析-masterHook的使用入口逆向分析.ht
212.checkpoint分析-自定义masterHook示例及测试.ht
213.checkpoint分析-SourceOperatorStreamTask中触发checkpoint的流程.ht
214.checkpoint分析-SourceTask的checkpoint-初始化input channel 快照的输出器.ht
215.checkpoint分析-SourceTask的input飞行数据[inflightData]快照逻辑.ht
216.checkpoint分析-对state进行checkpoint的核心方法主体步骤分析.ht
217.checkpoint分析-向下游广播barrier并对输出缓存队列进行快照存储的流程.ht
218.checkpoint分析-ResultPartition中的输出缓存队列快照数据写出的细节流程.ht
219.checkpoint分析-状态的checkpoint同步阶段主流程分析.ht
220.checkpoint分析-状态的checkpoint异步阶段主流程分析.ht
221.checkpoint分析-算子状态snapshot同步阶段关键细节1-调用算子.snapshotState() .ht
222.checkpoint分析-算子状态snapshot同步阶段关键细节2-快照策略中的两大步骤.ht
223.checkpoint分析-算子状态snapshot同步阶段-快照策略中的同步准备快照资源.ht
224.checkpoint分析-算子状态snapshot同步阶段-生成(异步输出逻辑)的流程.ht
225.checkpoint分析-算子状态snapshot异步阶段-在异步线程池中执行同步阶段所生成的“快照输出”..
226.checkpoint分析-算子状态snapshot异步阶段执行完后向master端CheckpointCoordinator确认.ht
227.checkpoint分析-master端的CheckpointCoordinator向subTask通知complete消息.ht
228.checkpoint分析-非sourceTask的checkpoint触发背景介绍.ht
229.checkpoint分析-barrier触发checkpoint的对齐、非对齐等模式设计要点.ht
230.checkpoint分析-barrier从nettyClient进入inputChannel的输入buffer队列的流程.ht
231.checkpoint分析-streamTask的mailboxLoop调用checkpoint取到barrier的流程.ht
232.checkpoint分析-barrierHandler对barrier进行处理的主流程.ht
233.checkpoint分析-非对齐checkpoint核心步骤1-对输入方向反序列化器中的buffer做快照.ht …
234.checkpoint分析-非对齐checkpoint核心步骤2-对输入方向receivedBuffers队列中的buffer做快照....
235.checkpoint分析-非对齐checkpoint核心步骤3-触发globalCheckpoint[广播barrier，对输出缓存做..
236.checkpoint分析-对齐checkpoint的步骤速览.ht
237.状态管理-flink的状态管理机制概述.ht
238.状态管理-flink的state状态类型设计及继承体系.ht
239.状态管理-分析flink的各类state底层用于存储状态数据的容器.ht
240.状态管理-copyOnWriteStateTable源码分析1-keyGroupRange与StateMap的对应关系.ht
241.状态管理-copyOnWriteStateMap数据结构原理.ht
242.状态管理-copyOnWriteStateMap等类的核心成员及构造源码.ht
243.状态管理-copyOnWriteStateTable定位数据的基本流程解析.ht
244.状态管理-copyOnWriteStateMap的copyOnWrite功能实现原理.ht
245.状态管理-copyOnWriteStateMap的增删改查源码解读1.mp4.ht
246.状态管理-copyOnWriteStateMap的增删改查源码解读2.ht
247.状态管理-copyOnWriteStateMap的扩容和rehash机制-1.ht
248.状态管理-copyOnWriteStateMap的扩容和rehash机制-2.ht
249.状态管理-copyOnWriteStateMap的扩容和rehash机制-3.ht
250.状态管理-CopyOnWriteStateMap的快照机制分析.ht
251.状态管理-stateTable中的当前key (keyContext)是如何更新的.ht
252.状态管理-task恢复状态的流程分析-1 .ht
253.状态管理-所谓状态后端的正确理解.ht
254.状态管理-task恢复状态的流程分析-2 .ht
255.状态管理-task恢复状态数据所需要的信息持有者(TaskStateManagerlmpl)分析.ht
256.状态管理-简要介绍-jobmanager端给task分配要恢复的状态信息.ht
257.新架构sink新架构sink涉及的一系列接口介绍- 1.ht
258.新架构sink新架构sink涉及的一-系列接口介绍-1.ht
259.新架构sink观察新架构source所生成的执行图.ht
260.新架构sink- sinkWriterOperator的整体了解核心成员及方法的理解.ht
261.新架构sink- sinkWriterOperator的构造方法分析.ht
262.新架构sink- sinkWriterOperator的状态初始化流程分析.ht
263.新架构sink- kafkaSink中的KafkaWriter构造整体流程.ht
264.新架构sink- kafkaWriter构造中的FlinkKafkalnternalProducer构造流程.ht
265.新架构sink- FlinkKafkalnternalProducer中原生producer的构造.ht
266.新架构sink- KafkaSinkWriter输出数据到kafka的流程.ht
267.新架构sink- sinkWriterOperator在checkpoint过程中的核心处理逻辑.ht
268新架构sink sinkWriterOperator向commiter发送可提交物的过程.ht
269.新架构sink- committerOperator的processElement方法核心逻辑.ht
270.新架构sink- commiterOperator提交事务的核心流程.ht
271.新架构sink-commiterOperator的状态快照及状态恢复(事务恢复)流程.ht

• javacc 基本原理、上手及实战案例
• calcite 基本原理、上手及实战案例
• calcite的HepPlanner和VolcanoPlanner优化器原理及源码解析
• flinksql的整体执行流程解析
• 逻辑计划详解
• 物理执行计划详解
• 优化器引擎工作原理
• 执行计划应用优化规则的原理
• 典型优化规则详解
• 自定义优化规则扩展案例
• 连接器架构解析
• 常用典型sql算子解析（如join，agg等）

热身案例

01.flinksql-lookup-join-源码二次开发案例-需求背景问题重现.mp4
02.flinksql-lookup-join-源码二次开发案例-添加自定义过滤条件参数及通过校验.mp4
03.flinksql-lookup-join-源码二次开发案例-定位lookup底层的查询逻辑.mp4
04.flinksql-lookup-join-源码二次开发案例-核心逻辑扩展及功能测试.mp4
06.flink-cdc-自动全库同步etl框架源码分析-修改参数解决故障.mp4
07.flinkc-cdc全库自动同步etl框架源码分析-启动流程及pipeline构建流程1-构建并添加source算子.mp4
08.flink-cdc全库自动同步etl源码分析-pipeline构建流程2-构建并添加map算子-路由映射实现.mp4
09.flink-cdc全库自动同步etl源码分析-.mp4
10.flink-cdc全库同步etl源码分析.mp4

正式内容

001.flinksql源码分析-概述及前言-1.ht
002.flinksql源码分析-概述及前言-2.ht
003.javacc基本介绍.ht
004.javacc的开发环境安装配置.ht
005.javacc入门案例1-两数运算表达式语法解析.ht
006.javacc入门案例2-复杂表达式语法解析.ht
007.javacc实战案例3-sql解析需求及树结构设计.ht
008.javacc实战案例3-sqINode数据结构类开发.ht
009.javacc实战案例3-sql语法中的token定义.ht
010.javacc实战案例3-select及字段列表的解析.ht
011.javacc实战案例3-join及table的解析.ht
012.javacc实战案例3-解析类的补充及测试观察.ht
013.calcite基本介绍.ht
014.calcite与关系代数的理解.ht
015.calcite的整体架构解析-sql解析及验证模块.ht
016.calcite的整体架构解析-优化器与优化规则.ht
017.calcite的核心工作流程及示例代码解析.ht
018.calcite原理解析1-sql解析成抽象语法树(AST)sqlnode的原理.ht
019.calcite原理解析-2-元数据校验及sqlNode转成逻辑执行计划的原理.ht
020.calcite原理解析-3-HepPlanner和VolcanoPlanner的特点介绍.ht
021.calcite原理解析-4-HepPlanner的原理流程.ht
022.calcite原理解析-5-HepPlanner中规则顺序对优化结果的影响.ht
023.calcite原理解析-6-自定义优化规则示例.ht
024.calcite原理解析-HepPlanner核心工作机制总结.ht
025.calcite原理解析-VolcanoPlanner的核心思想介绍.ht
026.calcite原理解析-VolcanoPlanner上手使用.ht
027.calcite原理解析-VolcanoPlanner的初始规则注册及规则应用效果测试.ht
028.calcite原理解析-VolcanoPlanner的核心工作机制说明.ht
029.calcite原理解析-VolcanoPlanner注册初始计划树后的等价集生成.ht
030.calcite原理解析-VolcanoPlanner初始化relset的源码跟踪.ht
031.calcite原理解析-VolcanoPlanner注册reInode过程中进行规则匹配的源码分析.ht
032.calcite原理解析-VolcanoPlanner的findBestExp()中的核心流程简述.ht
033.calcite原理解析-VolcanoPlanner的findBestExp()在规则应用后的等价集搜索空间分析.ht
034.calcite原理解析-VolcanoPlanner中规则迭代应用的原理解读.ht
035.calcite原理及解析-relnode节点成本的计算原理.ht
036.calcite原理及解析-filter节点前推project后成本计算分析.ht
037.calcite原理解析-逻辑执行计划和物理执行计划的朴素理解.ht
038.calcite原理解析-关于Trait和TraitDef和Convention等的理解.ht
039.calcite原理解析-逻辑执行计划转物理执行计划的原理分析.ht
040.calcite原理解析-自定义物理算子和转换规则.ht
041.calcite原理解析-自定义元数据管理系统.ht
042.flinksql源码分析-前言介绍.ht
043.flinksql源码分析-StreamTableEnvironment的创建及其各组件的创建.ht
044.flinksql源码分析-使用sql语句来建表的源码流程1.ht
045.flinksql源码分析-使用sql语句来建表的源码流程2.ht
046.flinksql源码分析-使用table-api方式建表的源码流程.ht
047.flinksql源码分析-tableApi方式建表时是否往catalog中注册的灵异现象分析.ht
048.table-api生成operationTree的源码流程.ht
049.sql方式下的select语句执行流程-语法解析得到抽象语法树SqlNode.ht
050.sql方式下的select语句执行流程-SqlNode转换成Operation的整体流程.ht
051.sql方式下的select语句执行流程-sqlnode转成关系代数数(逻辑执行计划)的源码流程.ht
052.sql方式下的insert-select语句转成operation树的源码流程.ht
053.operation转成transformation生成StreamGraph并执行的整体流程分析.ht
054.operation转成transformation的四大核心步骤说明.ht
055.modifySinkOperation转成完整relNode树的整体逻辑分析.ht
056.modifySinkOperation的查询部分转成relNode子树的源码流程.ht
057.modifySinkOperation转成的LogicSink节点的数据结构分析.ht
058.LogicalSink创建过程中获取DynamicTableSink工厂的源码流程.ht
059.利用DynamicTableSink工厂创建TableSink进而创建LogicalSink得到完整逻辑执行计划树.ht
060.执行计划优化-1-优化过程中的核心概念和核心原理说明.ht
061.optimize (计划优化）源码分析-1-拆分子图优化和合并重用优化子图的整体逻辑.ht
062.optimize (计划优化)源码分析-2-flinkChained链式优化程序构建及各类优化规则添加.ht
063.optimize (计划优化）源码分析-3-完整优化流程分析及计划类型转换的观察.ht
064.逻辑计划、物理计划、执行计划中的数据结构对比分析.ht
065.物理计划转成execNodeGraph(执行计划图)的整体流程分析.ht
066.物理计划节点转成exec节点举例-physicalTableScan和physicalTableSink转execNode.ht
067.execNodeGraph复杂案例数据结构观察与分析.ht
068.execNodeGraph递归遍历转成transformation列表的整体流程分析.ht
069.StreamExecTableSourceScan转成SourceTransformation的源码分析.ht
070.StreamExecCalc节点转成OnelnputTransformation的源码分析(动态代码生成算子) .ht
071.StreamExecSink节点转成SinkTransformation及后续转成StreamGraph并提交job的流程.ht
072.flinksql运行时-算子-概述.ht
073.flinksql运行时-source-连接器与运行时算子的联系原理回顾.ht
074.自定义sql连接器-物理数据源SourceFunction开发.ht
075.自定义sql连接器-TableSourceFactory和TableSource接口的方法解释.ht
076.自定义sql连接器-DynamicTableSourceFactory开发.ht
077.自定义sql连接器-DynamicTableSource开发.ht
078.自定义sql连接器-将Factory类加入META-INF以让SPI发现加载.ht
079.自定义sql连接器-tableSource的lookup特性支持概述.ht
080.自定义sql连接器-lookupTableSource开发实现.ht
081.flinksql运行时-算子-算子概念的理解和分析方式.ht
082.flinksql运行时-算子-sql到算子的快速定位法.ht
083.flinksql运行时-算子分析案例-简单过滤查询.ht
084.flinksql运行时-动态代码算子的代码生成时机和原理.ht
085.flinksql运行时-案例演示-动态生成代码的原理.ht
086.flinksql运行时-案例演示-动态编译生成的代码并加载实例调用.ht
087.flinksql运行时-动态代码算子的编译加载及实例化时机分析.ht
088.flinksql运行时-算子分析案例-groupBy聚合的运行时算子分析.ht
089.flinksql运行时-算子分析案例-窗口聚合的运行时算子分析1.ht
090.flinksql运行时-算子分析案例-窗口聚合的运行时算子分析2.ht
091.flinksql运行时-算子分析案例-常规join的运行时算子分析.ht
092.flinksql运行时-算子分析案例-窗口join的运行时算子分析1.ht
093.flinksql运行时-算子分析案例-窗口join的运行时算子分析2.ht
094.flinksql运行时-算子分析案例-lookup _join的运行时算子分析1.ht
095.flinksql运行时-算子分析案例-lookup_join的运行时算子分析2.ht
096.flinksql运行时-算子分析案例-lookup_join的运行时算子分析3.ht