95-170-046-源码-Time-Flink时间系统系列之ProcessFunction使用分析

1.世界 2.概述 ​ ProcessFunction 是flink 提供面向用户low-level 层级的api,通过ProcessFunction可以访问state、注册处理时间/事件时间定时器来帮助我们完成一些比较复杂的操作。 ​ 但是其有一个限制那就是只用使用在keyedStream中,是由于根据getRuntimeContext 得到的StreamingRuntimeContext 只提
相关文章
相关标签/搜索