#

迟到数据

  • 【Flink】Flink对于迟到数据的处理

    设置允许延迟的时间是通过allowedLateness(lateness: Time)设置保存延迟数据则是通过sideOutputLateData(outputTag: OutputTag[T])保存

    作者:13157330443
    2020-06-05 01:09:20