当时间特征是事件时间时,如何获取事件的摄取时间?

bwitn5fc  于 2021-06-26  发布在  Flink
关注(0)|答案(1)|浏览(288)

我想评估事件到达系统和完成之间花费的时间,我认为获取摄取时间会有所帮助,但是如何获取它呢?

niwlg2el

niwlg2el1#

您可能想使用延迟跟踪。或者,您可以将处理时间直接添加到链式流程函数中的源之后(使用 Context->TimerService#currentProcessingTime() ).

相关问题