分类： 数据之美

前面几节内容已经演示了如何使用Flink状态进行计算，如何对状态进行保存、恢复。要实现状态的应用计算和保存恢复… 继续阅读 Flink从入门到实战八[State]-13-Flink状态容错

前面的章节已经讲解了Flink状态的分类和代码示例，我们来对比一下Key State 与 Operator S… 继续阅读 Flink从入门到实战八[State]-12-Flink Key State 与 Operator State 区别

基于前一节我们已经对Broadcast State和其API有了一定了解，本节我们一起来编写代码，实现一个de… 继续阅读 Flink从入门到实战八[State]-11-Flink Broadcast State 广播状态使用示例

Broadcast State （广播状态）：广播状态是一种特殊的算子状态。引入它的目的在于支持一个流中的元素… 继续阅读 Flink从入门到实战八[State]-10-Flink Broadcast State 广播状态

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

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

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

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

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

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

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

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

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