broadcast

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

クラスターに読み取り専用の変数をブロードキャストする

このページをすべて展開する

構文

result = broadcast(sc,value)

説明

result = broadcast(sc,value) は、SparkContext sc で初期化されたクラスターに読み取り専用の変数 value をブロードキャストします。

入力引数

すべて展開する

使用する SparkContext。SparkContext オブジェクトとして指定します。

ブロードキャストする値。サポートされている任意のデータ型として指定します。

データ型: single | double | int8 | int16 | int32 | int64 | uint8 | uint16 | uint32 | uint64 | logical | char | struct | table | cell | function_handle | categorical | string

出力引数

すべて展開する

ブロードキャスト変数。次のプロパティをもつブロードキャスト オブジェクトとして返されます。

  • id

  • value

  • path

例

すべて展開する

クラスターに読み取り専用の変数をブロードキャストします。

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

%% broadcast
myRdd = sc.parallelize({1,2,3,4,5});
myBroadcast = sc.broadcast('Hello, World');
newRdd = myRdd.map(@(x) myBroadcast.value);
countdata = newRdd.collect()

バージョン履歴

R2016b で導入