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

时间:2024-07-01 20:31:47

提供分流能力

表8 提供分流能力的相关接口

API

说明

def split(selector: OutputSelector[T]): SplitStream[T]

传入OutputSelector,重写select方法确定分流的依据即打标记,构建SplitStream流。即对每个元素做一个字符串的标记,作为选择的依据,打好标记之后就可以通过标记选出并新建某个标记的流。

def select(outputNames: String*): DataStream[T]

从一个SplitStream中选出一个或多个流。

outputNames指的是使用split方法对每个元素做的字符串标记的序列。

support.huaweicloud.com/devg3-mrs/mrs_07_050041.html