华为云首页用户手册

MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供Join能力

MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供Join能力

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

MAPREDUCE服务 MRS

提供Join能力

**表12** 提供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方法进行指定，代表两条流通过该等值条件进行分区处理。

上一篇：MAPREDUCE服务 MRS-Flink Scala API接口介绍:Flink常用接口

下一篇：MAPREDUCE服务 MRS-Flink Scala API接口介绍:Flink常用接口

新客秒杀 2核2G 3M L实例

68元/年

普惠上云领千元上云礼券

立即前往

企业专享 X实例 4核8G 5M

888元/年

热门域名 1元随心购

1元/年起

MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供Join能力

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

推荐文章

解决方案
相关专题