编程之美 – 第 88 页 – 编程技术之美-IT之美

Flink从入门到实战八[State]-9-Flink Operator State的ListCheckpointed使用方法

发表于2022年7月17日2023年7月22日作者 IT之美

通过实现 ListCheckpointed 接口来使用 operator state。ListCheckpoi… 继续阅读 Flink从入门到实战八[State]-9-Flink Operator State的ListCheckpointed使用方法

Flink从入门到实战八[State]-8-Flink Operator State的CheckpointedFunction使用方法

发表于2022年7月15日2023年7月22日作者 IT之美

通过实现 CheckpointedFunction 接口来使用 operator state。Checkpoi… 继续阅读 Flink从入门到实战八[State]-8-Flink Operator State的CheckpointedFunction使用方法

Flink从入门到实战八[State]-7-Flink Operator State 算子状态

发表于2022年7月13日2023年7月22日作者 IT之美

Operator State（算子状态）：在同一个算子上的状态，对当前算子的所有数据是共享的。需要注意的是St… 继续阅读 Flink从入门到实战八[State]-7-Flink Operator State 算子状态

Flink从入门到实战八[State]-6-Flink State 状态过期与清理

发表于2022年7月11日2023年7月22日作者 IT之美

Flink里任何类型的keyed state都可以有有效期 (TTL)。如果配置了 TTL 且状态值已过期，… 继续阅读 Flink从入门到实战八[State]-6-Flink State 状态过期与清理

Flink从入门到实战八[State]-5-Flink Keyed State MapState API使用方法

发表于2022年7月9日2023年7月22日作者 IT之美

我们来看一下使用MapStateDescriptor和MapState，基于状态如何累计计算一个用户的交易数据… 继续阅读 Flink从入门到实战八[State]-5-Flink Keyed State MapState API使用方法

Flink从入门到实战八[State]-4-Flink Keyed State ValueState新版API使用方法

发表于2022年7月7日2023年7月22日作者 IT之美

我们来看一下使用ValueStateDescriptor和ValueState，基于状态如何累计计算一个用户的… 继续阅读 Flink从入门到实战八[State]-4-Flink Keyed State ValueState新版API使用方法

Flink从入门到实战八[State]-3-Flink Keyed State ValueState旧版API使用方法

发表于2022年7月5日2023年7月22日作者 IT之美

我们来看一下使用ValueStateDescriptor和ValueState，基于状态如何累计计算一个用户的… 继续阅读 Flink从入门到实战八[State]-3-Flink Keyed State ValueState旧版API使用方法

Flink从入门到实战八[State]-2-Flink Keyed State

发表于2022年7月3日2023年7月22日作者 IT之美

Keyed State基于每个key进行状态存储，是KeyedStream上的状态。支持的数据类型有：Valu… 继续阅读 Flink从入门到实战八[State]-2-Flink Keyed State

Flink从入门到实战八[State]-1-Flink State是什么

发表于2022年7月1日2023年7月22日作者 IT之美

什么是Flink有状态计算？在传统的流式计算中，要获取历史计算结果，都是需要从外部获取的，并且为了下次计算能够… 继续阅读 Flink从入门到实战八[State]-1-Flink State是什么

idea运行程序报错 java 程序包org.junit不存在

发表于2022年6月29日2023年7月15日作者 IT之美

idea运行程序报错：java: 程序包org.junit不存在第一种可能，是你的pom中没有引入junit… 继续阅读 idea运行程序报错 java 程序包org.junit不存在

Flink Table & sql执行报错：Make sure a planner module is on the classpath

发表于2022年6月27日2023年7月15日作者 IT之美

Flink Table & sql执行报错：原因是因为代码和pom引入的jar不一致。我当前测试代码… 继续阅读 Flink Table & sql执行报错：Make sure a planner module is on the classpath

Flink从入门到实战七[ProcessFunction]-5-侧流输出

发表于2022年6月25日2023年7月22日作者 IT之美

侧流是什么，这个名字听起来有点奇怪，侧流的作用就是在主流处理过程中，再定义一个或多个输出流，输出一些额外的信息… 继续阅读 Flink从入门到实战七[ProcessFunction]-5-侧流输出

Flink从入门到实战七[ProcessFunction]-4-CoProcessFunction使用

发表于2022年6月23日2023年7月22日作者 IT之美

当有两条输入流输入数据，DataStream API提供了CoProcessFunction。CoProces… 继续阅读 Flink从入门到实战七[ProcessFunction]-4-CoProcessFunction使用

Flink从入门到实战七[ProcessFunction]-3-Timer和TimerService

发表于2022年6月21日2023年7月22日作者 IT之美

ProcessFunction中一个强大的功能就是定时器了。定时器可以支持我们设定在某个时间触发执行某些必要的… 继续阅读 Flink从入门到实战七[ProcessFunction]-3-Timer和TimerService

Flink从入门到实战七[ProcessFunction]-2-KeyedProcessFunction使用

发表于2022年6月19日2023年7月22日作者 IT之美

KeyedProcessFunction是在业务开发中应用最多的ProcessFunction，用在Keyed… 继续阅读 Flink从入门到实战七[ProcessFunction]-2-KeyedProcessFunction使用

Flink从入门到实战七[ProcessFunction]-1-ProcessFunction是什么

发表于2022年6月17日2023年7月22日作者 IT之美

Flink从较新的版本之后，API分为四层：1、SQL2、TABLE API3、DataSet/DataStr… 继续阅读 Flink从入门到实战七[ProcessFunction]-1-ProcessFunction是什么

Flink从入门到实战六[Watermark]-5-Flink自带的Watermark

发表于2022年6月15日2023年7月22日作者 IT之美

Flink自带的Watermark类，最主要的就是BoundedOutOfOrdernessWatermark… 继续阅读 Flink从入门到实战六[Watermark]-5-Flink自带的Watermark

Flink从入门到实战六[Watermark]-4-自定义Watermark

发表于2022年6月13日2023年7月22日作者 IT之美

自定义 Watermark生成器，需要实现WatermarkGenerator接口。 watermark 的生… 继续阅读 Flink从入门到实战六[Watermark]-4-自定义Watermark

Flink从入门到实战六[Watermark]-3-Watermark的使用

发表于2022年6月11日2023年7月22日作者 IT之美

WatermarkStrategy 可以在 Flink 应用程序中的两处使用，第一种是直接在数据源上使用，第二… 继续阅读 Flink从入门到实战六[Watermark]-3-Watermark的使用

Flink从入门到实战六[Watermark]-2-Watermark API深入理解

发表于2022年6月9日2023年7月22日作者 IT之美

前面的内容我们已经了解了Watermark是什么，简单来说Watermark就是用来解决乱序事件和迟到时间的一… 继续阅读 Flink从入门到实战六[Watermark]-2-Watermark API深入理解