特牛生活网

大数据——Flink ProcessFunction API_statettlconfig.ttltimecharacteristic.eventtime-CSDN博客

网友收藏
文章浏览阅读150次。Flink ProcessFunction API概述KeyedProcessFunctionTimerService和定时器(Timers)概述我们之前学习的转换算子是无法访问事件的时间戳信息和水位线信息的。而在这一些应用场景下,极为重要。例如MapFunction这样的map转换算子就无法访问时间戳或者当前事件的事件时间。基于此,DataStream API提供了一系列的Low-Level转换算子。可以访问时间戳、watermark以及注册定时事件。还可以输出特定的一些事件,例如超时事件等。_statettlconfig.ttltimecharacteristic.eventtime