The ProcessFunction 低級的流處理操做

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