有时候tumble window的窗口设置的比较大,譬如1个小时,甚至1天,那么我们是不是只能在窗口结束之后才能看到数据呢?是否看到中间数据?
答案是肯定。
实现方式在代码中设置如下两个参数:
table.exec.emit.early-fire.enabled 开启提前触发窗口计算,并输出结果, 默认值: falsetable.exec.emit.early-fire.delay 提前触发窗口计算的间隔时间
TableConfig config = tenv.getConfig(); config.getConfiguration().setBoolean("table.exec.emit.early-fire.enabled",true); config.getConfiguration().setString("table.exec.emit.early-fire.delay","10s"); //每10秒钟触发一次输出
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)