[帮助文档] 基于DLF、RDS或Flink、OSS支持Delta Lake或Hudi存储机制

Delta Lake和Hudi是数据湖方案中常用的存储机制,为数据湖提供流处理、批处理能力。MaxCompute基于阿里云DLF、RDS或Flink、OSS产品提供了支持Delta或Hudi存储机制的湖仓一体架构。您可以通过MaxCompute查询到实时数据,即时洞察业务数据变化。

2021年最新最全Flink系列教程__Flink容错机制(五)

day05_Flink容错机制今日目标Flink容错机制之CheckpointFlink容错机制之重启策略存储介质StateBackendCheckpoint 配置方式状态恢复和重启策略Savepoint手动重启并恢复并行度设置Flink状态管理状态就是基于 key 或者 算子 operator 的...

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图
Flink教程(14)- Flink高级API(容错机制)

Flink教程(14)- Flink高级API(容错机制)

01 引言在前面的博客,我们学习了Flink的一些高级API,有兴趣的同学可以参阅下:《Flink教程(01)- Flink知识图谱》《Flink教程(02)- Flink入门》《Flink教程(03)- Flink环境搭建》《Flink教程(04ÿ...

Apache Flink 零基础入门教程(六):状态管理及容错机制

Apache Flink 零基础入门教程(六):状态管理及容错机制

**作者:孙梦瑶整理:韩非** 本文主要分享内容如下: 状态管理的基本概念; 状态的类型与使用示例; 容错机制与故障恢复; 一.状态管理的基本概念 1.什么是状态 首先举一个无状态计算的例子:消费延迟计算。假设现在有一个消息队列,消息队列中有一个生产者持续往消费队列写入消息,多个消费者分别从消息队列...

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

产品推荐

热门帮助文档

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载