华为云首页用户手册

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

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

时间：2024-07-01 09:37:46

MAPREDUCE服务 MRS Flink常用API介绍

提供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接口介绍:提供分流能力

下一篇：MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供分流能力

华为云11.11 2核1G 2M 云服务器

29元/年

立即注册领万元上云礼券

抽奖赢11111元免单

续费同价 L实例 2核2G 4M

98元/年

热门域名 1元随心购

1元/年

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

意见反馈

0/200

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

推荐文章

解决方案
相关专题