华为云首页用户手册

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

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

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

MAPREDUCE服务 MRS Flink常用API介绍

提供分流能力

表8 提供分流能力的相关接口
API	说明
def split(selector: OutputSelector[T]): SplitStream[T]	传入OutputSelector，重写select方法确定分流的依据(即打标记)，构建SplitStream流。即对每个元素做一个字符串的标记，作为选择的依据，打好标记之后就可以通过标记选出并新建某个标记的流。
def select(outputNames: String*): DataStream[T]	从一个SplitStream中选出一个或多个流。 outputNames指的是使用split方法对每个元素做的字符串标记的序列。

上一篇：MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供设置eventtime属性的能力

下一篇：MAPREDUCE服务 MRS-Flink Scala API接口介绍:提供设置eventtime属性的能力

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

68元/年

普惠上云领千元上云礼券

立即前往

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

888元/年

热门域名 1元随心购

1元/年起

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

意见反馈

0/200

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

推荐文章

解决方案
相关专题