文章 2022-12-30 来自:开发者社区

eBay:Flink的状态原理讲一下……

前言状态在 Flink 中叫作 State,用来保存中间计算结果或者缓存数据。根据是否需要保存中间结果,分为无状态计算和有状态计算。对于流计算而言,时间持续不断地产生,如果每次计算都是相互独立的,不依赖于上下游的事件,则是无状态计算。如果计算需要依赖于之前或者后续的事件,则是有状态计算。State 是实现有状态计算的下的 Exactly-Once 的基础。State的典型实例如:Sum求和、去重....

eBay:Flink的状态原理讲一下……
文章 2022-12-29 来自:开发者社区

《Flink中的两类新型状态存储》电子版地址

《Flink中的两类新型状态存储》Flink中的两类新型状态存储 电子版下载地址: https://developer.aliyun.com/ebook/3555 电子书: </div>

《Flink中的两类新型状态存储》电子版地址
文章 2022-11-26 来自:开发者社区

flink 状态后端详解

StateBackend在 Flink 中, 状态存储被叫做 StateBackend , 它具备两种能力:(1)在计算过程中提供访问 State 能力,开发者在编写业务逻辑中能够使用StateBackend 的接口读写数据。(2)能够将 State 持久化到外部存储,提供容错能力。一个 State Backend 主要负责两件事:Local State Management(本地状态管理) 和....

flink 状态后端详解
问答 2022-11-13 来自:开发者社区

大佬们,flink这个ck一直在这个状态,可能是什么原因?

大佬们,flink这个ck一直在这个状态,可能是什么原因?

问答 2022-11-08 来自:开发者社区

大佬们,flink这个ck一直在这个状态,可能是什么原因?

flink cdc导入数据到starRocks

文章 2022-11-05 来自:开发者社区

Apache Flink 概念介绍:有状态流式处理引擎的基石(二)| 学习笔记

开发者学堂课程【Apache Flink 入门到实战 - Flink 开源社区出品 :Apache Flink 概念介绍:有状态流式处理引擎的基石(二)】学习笔记,与课程紧密联系,让用户快速学习知识。课程地址:https://developer.aliyun.com/learning/course/632/detail/10037Apache Flink 概念介绍:有状态流式....

Apache Flink 概念介绍:有状态流式处理引擎的基石(二)| 学习笔记
问答 2022-10-31 来自:开发者社区

flink cdc 2.0 是分片机制,全量同步,怎么保障顺序同步?状态需要顺序的

flink cdc 2.0 是分片机制,全量同步,怎么保障顺序同步?状态需要顺序的

问答 2022-09-29 来自:开发者社区

flink sql客户端提交的job,怎么查看这个job的状态大小等情况?

flink sql客户端提交的job,怎么查看这个job的状态大小等情况?

问答 2022-09-29 来自:开发者社区

flink怎么广播数据到所有的task,我用广播状态跨算子访问不到

flink怎么广播数据到所有的task,我用广播状态跨算子访问不到

问答 2022-09-21 来自:开发者社区

flink状态编程的时候,是托管状态比如ValueState<T>这种,还需要实现自定义的ckp吗?

我并没有new 一个list这些来存储数据

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注