如何在KeyedProcessFunction中获取processingTime

[ゞ野蠻遊戲χ]

大家好

        当我在KeyedProcessFunction的processElement方法中获取processingTime，就像这样ctx.timestamp()，返回为null，我改如何在processElement中获取processingTime？


谢谢！
嘉治

[Zhao,Yi(SEC)]

根据Context获取timerService，然后获取处理时间即可。
________________________

在 2020/8/16 下午7:57，“ゞ野蠻遊戲χ”<[hidden email]> 写入:

    大家好
   
    &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;当我在KeyedProcessFunction的processElement方法中获取processingTime，就像这样ctx.timestamp()，返回为null，我改如何在processElement中获取processingTime？
   
   
    谢谢！
    嘉治

[shizk233]

ctx.timestamp()其实就是获取的StreamRecord的时间戳，也就是事件被提取出来的时间戳。
这个方法一般需要使用event time，并且在数据流上assign过timestamp和watermark。

ゞ野蠻遊戲χ <[hidden email]> 于2020年8月16日周日 下午7:57写道：

> 大家好
>
> &nbsp; &nbsp; &nbsp;
> &nbsp;&nbsp;当我在KeyedProcessFunction的processElement方法中获取processingTime，就像这样ctx.timestamp()，返回为null，我改如何在processElement中获取processingTime？
>
>
> 谢谢！
> 嘉治