95-170-046-源碼-Time-Flink時間系統系列之ProcessFunction使用分析

1.世界 2.概述 ​ ProcessFunction 是flink 提供面向用戶low-level 層級的api，通過ProcessFunction可以訪問state、註冊處理時間/事件時間定時器來幫助我們完成一些比較複雜的操作。 ​ 但是其有一個限制那就是隻用使用在keyedStream中，是由於根據getRuntimeContext 得到的StreamingRuntimeContext 只提

>>阅读原文<<