How do i get processingTime in keyedPrcessFounction

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

How do i get processingTime in keyedPrcessFounction

ゞ野蠻遊戲χ
Hi all

      When I get the processingTime in the processElement method of the KeyedProcessFunction, 
      like ctx.timestamp(), which returns null, how do I get the processingTime in processElement methoed?

Thanks,
Jiazhi
Reply | Threaded
Open this post in threaded view
|

Re: How do i get processingTime in keyedPrcessFounction

Mike Mintz
Hi Jiazhi,

Try ctx.timerService().currentProcessingTime()

Best,
Mike

On Sun, Aug 16, 2020 at 4:48 AM ゞ野蠻遊戲χ <[hidden email]> wrote:
Hi all

      When I get the processingTime in the processElement method of the KeyedProcessFunction, 
      like ctx.timestamp(), which returns null, how do I get the processingTime in processElement methoed?

Thanks,
Jiazhi