ApacheFlink-当时间特征为事件时间时,如何获取事件的摄取时间?


0

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

1 答案


0

您可能需要使用延迟跟踪。或者,您可以在 chaining式流程函数(使用Context->TimerServicecurrentProcessingTime())中直接将处理时间添加到源之后。


我来回答

写文章

提问题

面试题