flatMap

クラス: matlab.compiler.mlspark.RDD
名前空間: matlab.compiler.mlspark

まず既存の RDD のすべての要素に関数を適用し、次に結果をフラット化することにより、新しい RDD を返す

構文

result = flatMap(obj,func,varargin)


説明

result = flatMap(obj,func,varargin) はまず、obj のすべての要素に関数 func を適用して、次に結果をフラット化することにより、新しい RDD である result を返します。

入力引数

obj — 入力 RDD

RDD オブジェクト

関数を適用する入力 RDD。RDD オブジェクトとして指定します。

func — 各要素に適用する関数

関数ハンドル

入力 RDD の各要素に適用する関数。関数ハンドルとして指定します。

例:

データ型: function_handle

varargin — 可変長の入力引数のリスト

変換関数への有効な入力

適用する関数への入力を表す、可変長の入力引数のリスト。

出力引数

result — 出力 RDD

RDD オブジェクト

出力 RDD。RDD オブジェクトとして返されます。

例

RDD への関数の適用と結果のフラット化

%% Connect to Spark
sparkProp = containers.Map({'spark.executor.cores'}, {'1'});
conf = matlab.compiler.mlspark.SparkConf('AppName','myApp', ...
                        'Master','local[1]','SparkProperties',sparkProp);
sc = matlab.compiler.mlspark.SparkContext(conf);

%% flatMap
inRDD = sc.parallelize({'A','B'});
flatRDD = inRDD.flatMap(@(x)({x,1}));
viewRes = flatRDD.collect()

バージョン履歴

R2016b で導入

参考

flatMapValues | map | filter | collect | parallelize