flatMapValues

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

キーを変更せずに flatMap メソッドによってキーと値のペアの RDD の各値を渡す

構文

result = flatMapValues(obj,func)


説明

result = flatMapValues(obj,func) は、キーを変更せずに、flatMap メソッドによってキーと値のペアの RDD obj の各値を渡します。func は flatMap メソッドで適用する関数を表します。

入力引数

obj — 入力 RDD

RDD オブジェクト

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

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

関数ハンドル

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

例:

データ型: function_handle

出力引数

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);

%% flatMapValues
inRDD = sc.parallelize({ {'AA', {1,2,3}}, {'BB',3}, {'CC', {'cc',4}} });
f = @(x)(x);
out = inRDD.flatMapValues(f).collect();
% out : {{'AA',1},{'AA',2},{'AA',3},{'BB',3},{'CC','cc'},{'CC',4}}

バージョン履歴

R2016b で導入

参考

flatMap | map | collect | parallelize