阿里云文档 2025-05-27

基于DLF、RDS或Flink、OSS支持Delta Lake或Hudi存储机制

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

文章 2019-08-05 来自:开发者社区

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

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

Apache Flink 零基础入门教程(六):状态管理及容错机制
文章 2019-04-25 来自:开发者社区

Flink状态管理和容错机制介绍

作者: 施晓罡 本文来自2018年8月11日在北京举行的 Flink Meetup会议,分享来自于施晓罡,目前在阿里大数据团队部从事Blink方面的研发,现在主要负责Blink状态管理和容错相关技术的研发 本文主要内容如下: 有状态的流数据处理; Flink中的状态接口; 状态管理和容错机制实现; 阿里相关工作介绍; 一.有状态的流数据处理 1.1什么是有状态的计算 计算任务的结果不仅仅依赖...

Flink状态管理和容错机制介绍
问答 2019-02-14 来自:开发者社区

Apache Flink状态管理和容错机制介绍,对应视频和ppt有吗

转自钉钉群21789141:Apache Flink状态管理和容错机制介绍,对应视频和ppt有吗

文章 2018-11-14 来自:开发者社区

Flink状态管理和容错机制介绍

本文主要内容如下: 有状态的流数据处理; Flink中的状态接口; 状态管理和容错机制实现; 阿里相关工作介绍; 一.有状态的流数据处理# 1.1.什么是有状态的计算# 计算任务的结果不仅仅依赖于输入,还依赖于它的当前状态,其实大多数的计算都是有状态的计算。 比如wordcount,给一些word,其计算它的count,这是一个很常见的业务场景。count做为输出,在计算的过程中要不断的...

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

产品推荐

阿里云实时计算Flink

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

+关注