Flink onTime - processFunction

轉載做者:寫bug的張小天html 轉載地址:https://www.jianshu.com/p/e6297fac67cbjava Process Function(過程函數) ProcessFunction是一個低層次的流處理操做,容許返回全部(無環的)流程序的基礎構建模塊:   一、事件(event)(流元素)   二、狀態(state)(容錯性,一致性,僅在keyed stream中)   
相關文章
相關標籤/搜索