写点什么

flink 源码

0 人感兴趣 · 6 次引用

  • 最新
  • 推荐
https://static001.geekbang.org/infoq/5d/5db97a28a34a59637cb00c4d72b64188.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

Flink Collector Output 接口源码解析

在 Flink 中 Collector 接口主要用于 operator 发送(输出)元素,Output 接口是对 Collector 接口的扩展,增加了发送 WaterMark 的功能,在 Flink 里面只要涉及到数据的传递都必须实现这两个接口,下面就来梳理一下这些接口的源码。

https://static001.geekbang.org/infoq/5d/5db97a28a34a59637cb00c4d72b64188.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

Flink 侧流输出源码解析

Flink 的 side output 为我们提供了侧流(分流)输出的功能,根据条件可以把一条流分为多个不同的流,之后做不同的处理逻辑,下面就来看下侧流输出相关的源码。

https://static001.geekbang.org/infoq/5d/5db97a28a34a59637cb00c4d72b64188.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

给 Print SQL Connector 添加随机取样

Flink 提供了 Print SQL Connector 可以让我们非常方便的把数据打印到标准输出.有助于我们测试 SQL 任务,检验数据的正确性.

https://static001.geekbang.org/infoq/5d/5db97a28a34a59637cb00c4d72b64188.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

Flink 源码:广播流状态源码解析

Broadcast State 是 Operator State 的一种特殊类型。它的引入是为了支持这样的场景: 一个流的记录需要广播到所有下游任务,在这些用例中,它们用于在所有子任务中维护相同的状态。然后可以在处理第二个流的数据时访问这个广播状态,广播状态有自己的一些特性

https://static001.geekbang.org/infoq/cf/cf3d6944ed0f3b6cc7967a9a9c23a179.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

Flink 实现 MySQL CDC 动态同步表结构

本文讲述了如何将 Schema 的变化实时地从 MySQL 中同步到 Flink 程序中去

一文搞懂 FlinkSQL 函数 LAST_VALUE 的原理

用户头像
shengjk1
2021-03-23

刚开始接触 FlinkSQL 时,对 LAST_VALUE 特别好奇,虽然工作当中有在用到,但还是特别的想知道它是怎么实现的,今天终于可以总结一下

flink 源码_flink 源码技术文章_InfoQ写作社区