Flink小操作

阅读量：

等待迟到元素不关闭窗口

复制代码

    .timeWindow(Time.minutes(1), Time.seconds(10))
    .allowedLateness(Time.minutes(5))
    
    
    java

复制代码

     .timeWindow(Time.minutes(1), Time.seconds(10))
     .trigger(new MyTrigger)
    
    
    java

还没有任何评论哟~