问答 2021-12-03 来自:开发者社区

Flink sql count 多个属性的问题

大家好:         我在flink官方文档上看到内置聚合函数count的函数头是这样的         count([all] Expression | distinct Expression1 [, Expression2])         所以它应该可以对多个属性进行...

问答 2021-12-02 来自:开发者社区

Flink SQL是否支持Count Window函数?

今天遇到一个业务场景用到count window,查了下Flink官网目前Flink SQL只支持time window,问一下官方是否打算sql支持count window呢? 如果没有计划的话,自己要如何实现?是否可以像flink 1.13引入的cumulate window写一个自定义窗口函数呢?谢谢!*来自志愿者整理的flink邮件归档

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

flink sql 的 count(distinct )问题

各位大佬好,想问下flinksql里的count (distinct)默认是用哪种state保存的状态*来自志愿者整理的flink邮件归档

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

flink sql count distonct 优化应该怎么办?

在SQL中,如果开启了 local-global 参数:set table.optimizer.agg-phase-strategy=TWO_PHASE; 或者开启了Partial-Final 参数:set table.optimizer.distinct-agg.split.enabled=true; set table.optimizer.distinct-agg.split.bucket-....

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

产品推荐

阿里云实时计算Flink

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

+关注