TimeTimer共1篇
Flink / Scala 实战 - 19.ProcessFunction 删除 key 的上一个定时器 TimeTimer - MaxSSL

Flink / Scala 实战 – 19.ProcessFunction 删除 key 的上一个定时器 TimeTimer

一.引言ProcessFunction原始执行状态为每个key注册一个较长时间TimeTimer并在这期间将所有对应key的数据都收集起来,到期完成触发。现在接到新的需求,要求判断数据类型,当特殊标识的数据到达...
MaxSSL的头像 - MaxSSLMaxSSL2年前
810