栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink Sql 窗口聚合触发配置

Flink Sql 窗口聚合触发配置

flink:1.11

默认情况下,Flink Sql的窗口聚合在窗口结束时触发计算,如果需要实时计算,刷新计算结果,需添加如下配置:

 TableConfig config = bbTableEnv.getConfig();
 config.getConfiguration().setBoolean("table.exec.emit.early-fire.enabled", true);
 config.getConfiguration().setString("table.exec.emit.early-fire.delay", "1s");
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/345426.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号