95-138-010-源碼-Function-ProcessFunction

1.概述 一些算子和函數能夠進行一些時間上的操作，但是不能獲取算子當前的Processing Time或者是Watermark時間戳，調用起來簡單但功能相對受限。如果想獲取數據流中Watermark的時間戳，或者在時間上前後穿梭，需要使用ProcessFunction系列函數，它們是Flink體系中最底層的API，提供了對數據流更細粒度的操作權限。Flink SQL是基於這些函數實現的，一些需要高

>>阅读原文<<