Flink onTime - processFunction

转载做者:写bug的张小天html 转载地址:https://www.jianshu.com/p/e6297fac67cbjava Process Function(过程函数) ProcessFunction是一个低层次的流处理操做,容许返回全部(无环的)流程序的基础构建模块:   一、事件(event)(流元素)   二、状态(state)(容错性,一致性,仅在keyed stream中)   
相关文章
相关标签/搜索