阿里云文档 2024-09-12

使用UDAF实现数据排序和聚合

本文提供了一个自定义聚合函数(UDAF),实现将多行数据合并为一行并按照指定列进行排序,并以居民用电户电网终端数据为例,介绍如何在实时计算控制台使用该函数进行数据聚合和排序。

阿里云文档 2024-08-05

窗口聚合

实时计算Flink版的窗口聚合支持老语法分组窗口聚合(Group Window Aggregation)和新语法窗口表值函数聚合(Window TVF Aggregation)两种形式。本文为您介绍窗口聚合新老语法详情、窗口表值函数和聚合语句无法合并的场景、以及新老语法对更新流的支持情况。

文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之在物化视图上进行聚合操作如何解决

问题一:Flink CDC物化视图能不能做聚合? Flink CDC物化视图能不能做聚合? 参考回答: Flink CDC支持实时数据流的捕获和变更数据的同步,可以进行INSERT, DELETE, UPDATE等操作。然而,对于物化视图是否能进行聚合的问题,目前存在一些不同的观点。一种观点认为,Flink SQL不支持对由插入、更新、删除的流进行分组...

问答 2023-12-01 来自:开发者社区

Flink CDC物化视图能不能做聚合?

Flink CDC物化视图能不能做聚合?

阿里云文档 2023-06-01

如何针对资讯聚合类业务场景搭建基于云消息队列Kafka版和实时计算Flink的实时数仓

本文介绍如何针对资讯聚合类业务场景搭建基于云消息队列 Kafka 版和实时计算Flink的实时数仓。

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

产品推荐

阿里云实时计算Flink

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

+关注