Flink按统计Kafka中每小时的数量并输出到MySQL这篇文章中使用到 new TaskTimestamp 这个是什么?
专栏地址:https://blog.csdn.net/saranjiao/article/details/104922825
允许的延迟时间,水位线。assignTimestampsAndWatermarks(),在括号内ctrl+p,可以看到需要的类是TaskTimestamp,所以就new一个出来,放需要的值。