当watermark超过了窗口末尾时间时，晚到的元素默认会被丢弃，不过可以通过指定allowed lateness，容忍一定超时的数据转发到side output。

SingleOutputStreamOperator<T> result = input
    .keyBy(<key selector>)
    .window(<window assigner>)
    .allowedLateness(<time>)
    .sideOutputLateData(lateOutputTag)
    .<windowed transformation>(<window function>);