this.windowAssigner=TumblingWindowAssigner.of(size).withOffset(Duration.ofMillis(-offset)); | this.windowAssigner=SlidingWindowAssigner.of(size,slide); | TumblingWindowAssigner.of(size).withOffset(Duration.ofMillis(-offset)) | SlidingWindowAssigner.of(size,offset) | flink | 2e09d9479beb9b38e1de1f0662000e8c01336480 | org.apache.flink.table.runtime.window.WindowOperatorBuilder | | | | - org.apache.flink.table.runtime.window.assigners.SlidingWindowAssigner
- java.time.Duration
- org.apache.flink.table.runtime.window.assigners.TumblingWindowAssigner
| | Uses | True |