#

遲到數(shù)據(jù)

  • 【Flink】Flink對于遲到數(shù)據(jù)的處理

    設(shè)置允許延遲的時間是通過allowedLateness(lateness: Time)設(shè)置保存延遲數(shù)據(jù)則是通過sideOutputLateData(outputTag: OutputTag[T])保存

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