reduce

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

指定された可換的関数と結合関数を使用して RDD の要素を削減

構文

result = reduce(obj,func)


説明

result = reduce(obj,func) は、指定された可換的関数と結合関数 func を使用して obj の要素を削減します。

入力引数

obj — 入力 RDD

RDD オブジェクト

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

func — 関数ハンドルとして指定される、RDD の要素に適用する可換的関数および結合関数

関数ハンドル

RDD の要素に適用する可換的関数および結合関数。

データ型: function_handle

出力引数

result — 入力 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);

%% Reduce
reduceVal = sc.parallelize({1, 2, 3, 4, 5}).reduce(@(x,y)(x+y));
disp(reduceVal);

バージョン履歴

R2016b で導入

参考

fold | map | reduceByKey | reduceByKeyLocally | collect | parallelize