Flink sql中可以使用自定义窗口触发器吗

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink sql中可以使用自定义窗口触发器吗

KrisWu
Hi,想问下现在的Flink sql支持使用自定义窗口触发器吗?
Reply | Threaded
Open this post in threaded view
|

Re: Flink sql中可以使用自定义窗口触发器吗

Jark
Administrator
Hi,

目前是不支持的。不过有个实验性功能可以指定提前输出的策略和迟到处理的策略 [1],可能可以满足你的需求。

Best,
Jark

[1]:
https://github.com/apache/flink/blob/master/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala#L175

On Tue, 21 Jul 2020 at 22:28, 462329521 <[hidden email]> wrote:

> Hi,想问下现在的Flink&nbsp;sql支持使用自定义窗口触发器吗?