MAPREDUCE服务 MRS-Scala:提供设置eventtime属性的能力
提供设置eventtime属性的能力
API |
说明 |
---|---|
def assignTimestampsAndWatermarks(assigner: AssignerWithPeriodicWatermarks[T]): DataStream[T] |
为了能让event time窗口可以正常触发窗口计算操作,需要从记录中提取时间戳。 |
def assignTimestampsAndWatermarks(assigner: AssignerWithPunctuatedWatermarks[T]): DataStream[T] |
- 权限管理能力_怎么设置权限_云容器引擎
- Hudi服务_什么是Hudi_如何使用Hudi
- MapReduce服务_什么是Hive_如何使用Hive
- MapReduce服务_什么是MapReduce服务_什么是HBase
- MapReduce服务_什么是ClickHouse_如何使用ClickHouse
- MapReduce服务_什么是ZooKeeper_如何使用ZooKeeper
- 什么是主机监控_免费云监控_专业监控
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- MapReduce服务_什么是Hue_如何使用Hue
- MapReduce服务_什么是Loader_如何使用Loader