MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供设置eventtime属性的能力

时间:2024-06-29 14:11:45

提供设置eventtime属性的能力

表6 提供设置eventtime属性的能力的相关接口

API

说明

def assignTimestampsAndWatermarks(assigner: AssignerWithPeriodicWatermarks[T]): DataStream[T]

为了能让event time窗口可以正常触发窗口计算操作,需要从记录中提取时间戳。

def assignTimestampsAndWatermarks(assigner: AssignerWithPunctuatedWatermarks[T]): DataStream[T]

support.huaweicloud.com/devg-lts-mrs/mrs_07_050041.html