首页
学习
活动
专区
工具
TVP
发布

kk大数据

专栏作者
116
文章
197760
阅读量
42
订阅数
浅谈 Flink 的状态和容错(1)
都说 Flink 是有状态计算,那么什么是状态?状态有什么用?没有状态程序会怎么样?
kk大数据
2023-03-03
3660
Apache DolphinScheduler 2.0.1 来了,备受期待的一键升级、插件化终于实现!
好消息!Apache DolphinScheduler 2.0.1 版本今日正式发布!
kk大数据
2021-12-20
1.9K0
阅读 Flink 源码前必会的知识 - Java 8 异步编程 CompletableFuture 全解析
通常来说,程序都是顺序执行,同一时刻只会发生一件事情。如果一个函数依赖于另一个函数的结果,它只能等待那个函数结束才能继续执行,从用户角度来说,整个程序才算执行完毕。
kk大数据
2021-03-13
9550
Flink 状态管理详解(State TTL、Operator state、Keyed state)
Flink官网的自我介绍:Apache Flink® — Stateful Computations over Data Streams,可以看出状态计算是 Flink 引以为豪的杀手锏。那什么是带状态的计算呢?简单说计算任务的结果不仅仅依赖于输入,还依赖于它的当前状态。
kk大数据
2021-02-24
6.6K0
Flink Table API/SQL 是如何变成程序运行的
如上图,最下面一层是 Process Function ,可以去做一些有状态的计算,注册 Timer 定时器,可以做更复杂的操作,灵活性更高,可以做非常复杂的定制开发;
kk大数据
2020-12-29
1.1K0
Flink + Debezium CDC 实现原理及代码实战
Debezium 是一个分布式平台,它将现有的数据库转换为事件流,应用程序消费事件流,就可以知道数据库中的每一个行级更改,并立即做出响应。
kk大数据
2020-12-29
5.4K0
一文带你了解 Flink 基本组件栈
Flink 同样遵循着分层的架构设计理念,在降低系统耦合的同时,也为上层用户构建 Flink 应用提供了丰富且友好的接口。
kk大数据
2019-09-24
8180
Flink 编程接口
现实世界中,所有的数据都是以流式的形态产生的,不管是哪里产生的数据,在产生的过程中都是一条条地生成,最后经过了存储和转换处理,形成了各种类型的数据集。
kk大数据
2019-09-24
7210
没有更多了
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档