MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供Join能力
提供Join能力
API |
说明 |
---|---|
def join[T2](otherStream: DataStream[T2]): JoinedStreams[T, T2] |
通过给定的key在一个窗口范围内join两条数据流。 join操作的key值通过where和eaualTo方法进行指定,代表两条流过滤出包含等值条件的数据。 |
def coGroup[T2](otherStream: DataStream[T2]): CoGroupedStreams[T, T2] |
通过给定的key在一个窗口范围内co-group两条数据流。 coGroup操作的key值通过where和eaualTo方法进行指定,代表两条流通过该等值条件进行分区处理。 |
- 什么是Spark_如何使用Spark_Spark的功能是什么
- 华为云CodeArts API_接口迁移_接口导入
- MapReduce服务_什么是Hive_如何使用Hive
- MapReduce服务_什么是HDFS_HDFS特性
- 华为云CodeArts API_前后置脚本能力
- 使用API网关开放本地数据中心服务能力_开放API_API网关APIG-华为云
- ocr文字识别接口_ocr识别api_OCR接口
- 华为云CodeArts API_API测试_接口测试_关键字
- 调用GaussDB(DWS) API接口_数据仓库服务调用API_如何调用API_在DWS中调用API
- 106短信发送_短信接口API_短信群发助手