MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供设置eventtime属性的能力
提供设置eventtime属性的能力
API |
说明 |
---|---|
def assignTimestampsAndWatermarks(assigner: AssignerWithPeriodicWatermarks[T]): DataStream[T] |
为了能让event time窗口可以正常触发窗口计算操作,需要从记录中提取时间戳。 |
def assignTimestampsAndWatermarks(assigner: AssignerWithPunctuatedWatermarks[T]): DataStream[T] |