没有合适的资源?快使用搜索试试~ 我知道了~
flink-source-code-analysis:Apache Flink源码分析系列,基于git tag 1.1.2
共59个文件
png:36个
md:11个
ds_store:9个
0 下载量 149 浏览量
2021-03-24
01:57:39
上传
评论
收藏 3.27MB ZIP 举报
温馨提示
flink-源代码分析 Apache Flink源码分析系列,基于git tag 1.1.2 Apache Flink被视为第四代的大数据处理框架,它融合了流式计算和批处理【批处理被视为流式计算的特例】 在流式计算方面,使用分布式快照【检查点】实现了高效的数据不丢的机制从而实现准确的一次;使用WaterMark技术实现了窗口计算中延迟数据的处理,同时对流式计算的窗口时间定义分类:处理时间,摄取时间,事件时间 本人觉得flink的这些特性一定程序上可以窥探出大数据的未来方向,所以花了些时间来阅读源码,先共享出来希望和大家一起探讨 目前分为一下几个专题: flink基本组件和逻辑计划:介绍了flink的基本组件,实现重建的过程,以及客户端逻辑计划的生成过程 flink物理计划生成:介绍了flink JobManager对逻辑计划的运行时抽象,运行时物理计划的生成和管理等 jobmanage
资源详情
资源评论
资源推荐
收起资源包目录
flink-source-code-analysis-master.zip (59个子文件)
flink-source-code-analysis-master
flink
flink物理计划生成
execution-many-one.png 77KB
flink物理计划生成.md 26KB
flink-job-vertex-to-execution.png 96KB
job-graph-node-sort.png 74KB
execution-vertex-one-to-one.png 71KB
jobclient-to-jobmanager.png 65KB
.DS_Store 6KB
execution-one-many.png 78KB
jobmanager基本组件
jobmanager基本组件.md 15KB
blob-service-extends-arch.png 99KB
blob-server-store-dirctory-tree.png 100KB
zk-state-handle-storage.png 30KB
blob-server-cache-store.png 129KB
blob-server-contact.png 37KB
.DS_Store 6KB
flink对用户代码异常处理
flink用户异常处理.md 6KB
flink-scheduler
flink-scheduler.md 18KB
flink-streaming-deploy-flow.png 128KB
flink-slot-group.png 184KB
slots_parallelism.svg 989KB
.DS_Store 6KB
简历-陈玉兆.pdf 134KB
flink基本组件和JobGraph的生成
flink基本组件和逻辑计划生成.md 24KB
flink-datastream-extend.png 180KB
flink-on-yarn-arch.png 102KB
transformation-to-node.png 44KB
flink-cluster-start-flow.png 89KB
flink-job-graph-create.png 81KB
index.md 47B
.DS_Store 6KB
stream-operator-extend.png 137KB
flink-watermark-checkpoint
state-describtor.png 138KB
state-backend-extend.png 173KB
fs-snapshort-extend.png 126KB
flink-watermark-checkpoint.md 18KB
value-state-extend.png 293KB
.DS_Store 6KB
checkpoint-event-flow.png 143KB
.DS_Store 14KB
flink算子的生命周期
flink-operator-extend.png 137KB
op-chian-chianable.png 42KB
operator-chain-simple.png 23KB
op-chain-internal.png 113KB
stream-task-extend.png 107KB
.DS_Store 6KB
flink算子生命周期.md 13KB
taskmanager基本组件
taskmanager基本组件.md 9KB
memory-segment-extend.png 158KB
io-manager-async.png 39KB
.DS_Store 6KB
file-channel-entend.png 200KB
flink网络栈
intermediate-result.png 115KB
sub-partition.png 101KB
flink网络栈.md 29KB
netty-client-server.png 156KB
.DS_Store 6KB
flink-network-dataflow.png 90KB
README.md 2KB
LICENSE 11KB
共 59 条
- 1
徐志鹄
- 粉丝: 16
- 资源: 4661
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0