按时间归档:2023年5月25日
-
Flink常用API之转换算子的Connect算子
Connect,CoMap,CoFlatMap[DataStream ->ConnectedStream->DataStream]Connect 算子主要是为了合并两种…
-
Flink中State管理与恢复之CheckPoint的参数设置
默认情况下 Flink 不开启检查点的,用户需要在程序中通过调用方法配置和开启检查 点,另外还可以调整其他相关参数: 1.Checkpoint 开启和时间间隔指定: 开启检查点并且…
-
Flink State 管理与恢复
Flink 是一个默认就有状态的分析引擎,例如 WordCount 案例可以做到单词的数量的累加,其实是因为在内存中保证了每个单词的出现的次数,这些数据其实就是状态数据。但是如果一…
-
Flink中State管理与恢复之CheckPoint原理
Flink中State管理与恢复之CheckPoint原理 原创 wx62be9d88ce2942022-07-01 17:45:15博主文章分类:大数据 ©著作权 文章标签 fl…
-
Flink中State管理与恢复之状态后端Backend
默认情况下,State 会保存在 TaskManager 的内存中,CheckPoint 会存储在 JobManager 的内存中。State 和 CheckPoint 的存储位置…
-
Flink中State管理与恢复之状态后端Backend案例
Flink中State管理与恢复之状态后端Backend案例 原创 wx62be9d88ce2942022-07-01 17:45:40博主文章分类:大数据 ©著作权 文章标签 后…
-
Flink中Window详解之Window分类
Windows 计算是流式计算中非常常用的数据计算方式之一,通过按照固定时间或长度将 数据流切分成不同的窗口,然后对数据进行相应的聚合运算,从而得到一定时间范围内的统 计结果。例如…
-
Flink中State管理与恢复之Savepint案例
Savepoints 是检查点的一种特殊实现,底层实现其实也是使用 Checkpoints 的机制。 Savepoints 是用户以手工命令的方式触发 Checkpoint,并将结…
-
Flink中Window详解之Window的API
Flink中Window详解之Window的API 原创 wx62be9d88ce2942022-07-01 17:45:55博主文章分类:大数据 ©著作权 文章标签 flink …
-
Flink中Window详解之Window的聚合函数AggregateFunction
Flink中Window详解之Window的聚合函数AggregateFunction 原创 wx62be9d88ce2942022-07-01 17:46:01博主文章分类:大数…