Flink 定時器

定時器

基于處理時間或者事件時間處理過一個元素之后, 注冊一個定時器, 然后指定的時間執(zhí)行.

Context和OnTimerContext 所持有的TimerService對象擁有以下方法:

  • currentProcessingTime(): Long 返回當(dāng)前處理時間

  • currentWatermark(): Long 返回當(dāng)前watermark的時間戳

  • registerProcessingTimeTimer(timestamp: Long): Unit會注冊當(dāng)前key的processing time的定時器。當(dāng)processing time到達(dá)定時時間時，觸發(fā)timer。

  • registerEventTimeTimer(timestamp: Long): Unit 會注冊當(dāng)前key的event time 定時器。當(dāng)水位線大于等于定時器注冊的時間時，觸發(fā)定時器執(zhí)行回調(diào)函數(shù)。

  • deleteProcessingTimeTimer(timestamp: Long): Unit 刪除之前注冊處理時間定時器。如果沒有這個時間戳的定時器，則不執(zhí)行。

  • deleteEventTimeTimer(timestamp: Long): Unit 刪除之前注冊的事件時間定時器，如果沒有此時間戳的定時器，則不執(zhí)行。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容