在Blink SQL逻辑优化中，如何通过去重减少输出到sink算子的数据量？
在Blink SQL逻辑优化中，如何通过去重减少输出到sink算子的数据量？
使用Blink SQL+UDAF实现差值聚合计算
本案例根据某电网公司的真实业务需求，通过Blink SQL+UDAF实现实时流上的差值聚合计算，通过本案例，让读者熟悉UDAF编写，并理解UDAF中的方法调用关系和顺序。感谢@军长在实现过程中的指导。笔者水平有限，若有纰漏，请批评指出。 一、客户需求 电网公司每天采集各个用户的电表数据（格式如下表），其中data_date为电表数据上报时间，cons_id为电表id，r1为电表度数，其他字段与计....
blink sql中如何清除state中的数据
你好，实时数仓中A,B两个表join,如果A是一条带有delete操作的数据过来，与B表中的某条数据能join上， 请问怎么把A表中state存的那条数据清除掉，不清除的话，如果B表中来一条数据就能跟A那条delete的数据 join上，我想要的是不能join上。*来自志愿者整理的flink邮件归档
blink sql 实时计算,来源表5张,是否可以同时流join 2张以上的表
blink sql 实时计算,来源数据涉及5张表,每个表之间都互相都有关联,有些表是多条记录,有写表是一条数据,流的形式,是否可以同时join 5张表,如果之间有数据没有关联上,数据将会等到关联数据来时,在进行计算，是这样吗？
blink sql 实时计算,来源表5张,是否可以同时流join 2张以上的表
blink sql 实时计算,来源数据涉及5张表,每个表之间都互相都有关联,是否可以同时join 5张表,如果之间有数据没有关联上,数据将会等到关联数据来时,在进行计算，是这样吗？
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
数据库
分享数据库前沿，解构实战干货，推动数据库技术变革
+关注