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 中推出