The ProcessFunction 低級的流處理操做

The ProcessFunction ProcessFunction是一個低級的流處理操做，能夠訪問全部(非循環)流應用程序的基本組件:java Events(流元素) state (容錯, 一致性，只在KeyedStream上) timers (事件時間和處理時間，只在KeyedStream上) 能夠將ProcessFunction看作是具有訪問keyed狀態和定時器的FlatMapFunct

>>阅读原文<<