写点什么

flink源码分析

0 人感兴趣 · 5 次引用

  • 最新
  • 推荐

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写作平台