写点什么

flink源码分析

0 人感兴趣 · 6 次引用

  • 最新
  • 推荐

一文搞定 Flink Job 的运行过程

用户头像
shengjk14 月 22 日

之前我们知道了Flink 是如何生成 StreamGraph 以及 如何生成 job 和 如何生成Task,现在我们通过 Flink Shell 将他们串起来,这样我们就学习了从写代码开始到 Flink 运行 task 的整个过程是怎么样的。

Flink 源码分析之 Flink 自定义 source、sink 是如何起作用的

用户头像
shengjk12020 年 6 月 7 日

自从学会自定义source之后,一直都比较好奇,为什么我实现一个 *SourceFunction,我自己定义的代码就可以跟 Flink很好的整合在一起?

Flink 源码分析之 FlinkConsumer 是如何保证一个 partition 对应一个 thread 的

用户头像
shengjk12020 年 6 月 7 日

我们都知道flink 连接kafka时,默认是一个partition对应一个thread,它究竟是怎么实现的呢?以及到我们自己定义 RichParallelSourceFunction 的时候如何借鉴这部分代码呢?

flink源码分析_flink源码分析资料文章-InfoQ写作平台