val aggStream = dataStream
.filter(_.method == "GET")
.keyBy(_.url)
.timeWindow(Time.minutes(10), Time.seconds(5))
.allowedLateness(Time.minutes(1)) //允许延迟
.sideOutputLateData(new OutputTag[ApacheLogEvent]("late"))
.aggregate(new PageCountAgg(), new PageViewCountWindowResult())
希望有朋友可以帮忙解答一下