mapValues

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

キーを変更せずに map 関数によってキーと値のペアの RDD の各値を渡す

構文

result = mapValues(obj,func)


説明

result = mapValues(obj,func) は、キーを変更せずに map 関数 func によってキーと値のペアの RDD obj の各値を渡します。

入力引数

obj — 入力 RDD

RDD オブジェクト

入力 RDD。RDD オブジェクトとして指定します。

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

関数ハンドル

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

データ型: function_handle

出力引数

result — マッピングされた要素を含む RDD

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

%% mapValues
x = sc.parallelize({'A','B','A'});

% reduce by key the above keys and square each of the values, 
% so {'A',1} -> {'A',1*1}, {'B', 2} -> {'B', 2*2}

y = x.map(@(x)({x,1})).reduceByKey(@(x,y)(x+y)).mapValues(@(x)(x*x))
z = y.collect() % {{'A',4},{'B',1}}

バージョン履歴

R2016b で導入

参考

map | flatMap | collect | parallelize