Flink SQL Emit 输出策略
Posted @SmartSi
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink SQL Emit 输出策略相关的知识，希望对你有一定的参考价值。
传送门：Flink 系统性学习笔记
Flink 1.13.5
假设现在遇到这样一个场景，我们需要实时统计每分钟、每小时甚至每天的 PV 或者 UV。如果使用 Flink SQL 中的滚动窗口来计算，那么只能在每分钟、每小时或者每天结束的时候才能把结果输出。这种输出显然不满足我们的需求，有没有一种更实时的输出方案，例如，1 分钟的时间窗口，窗口触发之前希望每 10 秒都能看到最新的结果。针对这类提前输出的场景，可以在 Flink SQL 使用添加 EMIT 输出策略，如下所示启用提前输出策略：
table.exec.emit.early-fire.enabled =以上是关于Flink SQL Emit 输出策略的主要内容，如果未能解决你的问题，请参考以下文章
flink笔记13 [Table API和SQL] 查询表输出表查看执行计划