用户头像

shengjk1

还未添加个人签名

2018.4.26 加入

博客
https://blog.csdn.net/jsjsjs1789
关注
  • 14

    发布数

  • 57

    关注者

  • 70

    关注了

Flink 源码分析之写给大忙人看的 Flink Window 原理

Window 可以说是 Flink 中必不可少的 operator 之一,在很多场合都有很非凡的表现。今天呢,我们就一起来看一下 window 是如何实现的。

Flink 源码分析之一文搞懂 Flink 消息全流程

flink 是如何消费每条消息的

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

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

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

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

Flink 源码分析之 Flink startupMode 是如何起作用的

flink 源码分析之 Flink startupMode 是如何起作用的

Flink 源码分析之 - 如何保存 offset

Flink 源码分析之 - 如何保存 offset

写博客的那些事

写博客

工作 vs 生活
工作 vs 生活

​是为了幸福。

读 Guide to Java String Pool

简单介绍 String Pool

关于 Iterator 和 Iterable

Iterator 和 Iterable

一文搞定 equals 和 hashCode

讲述 java equals 和 hashcode,各自的注意事项以及使用场景

shengjk1