MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供设置eventtime属性的能力
提供设置eventtime属性的能力
API |
说明 |
---|---|
def assignTimestampsAndWatermarks(assigner: AssignerWithPeriodicWatermarks[T]): DataStream[T] |
为了能让event time窗口可以正常触发窗口计算操作,需要从记录中提取时间戳。 |
def assignTimestampsAndWatermarks(assigner: AssignerWithPunctuatedWatermarks[T]): DataStream[T] |
- 华为云CodeArts API_接口迁移_接口导入
- 华为云CodeArts API_如何在CodeArts API中设置API的设计规范?
- 权限管理能力_怎么设置权限_云容器引擎
- 什么是Spark_如何使用Spark_Spark的功能是什么
- 华为云CodeArts API_API测试_接口测试_关键字
- ocr文字识别接口_ocr识别api_OCR接口
- 华为云CodeArts API_前后置脚本能力
- Hudi服务_什么是Hudi_如何使用Hudi
- 华为云CodeArts API_如何在CodeArts API中设置请求参数?
- 华为云CodeArts API_如何利用CodeArts API设计一个接口?