The ProcessFunction 低级的流处理操做

The ProcessFunction ProcessFunction是一个低级的流处理操做,能够访问全部(非循环)流应用程序的基本组件:java Events(流元素) state (容错, 一致性,只在KeyedStream上) timers (事件时间和处理时间,只在KeyedStream上) 能够将ProcessFunction看作是具有访问keyed状态和定时器的FlatMapFunct
相关文章
相关标签/搜索