Exponenta Banner
exponenta event banner

broadcast

Класс: matlab.compiler.mlspark.SparkContext
Пакет: matlab.compiler.mlspark

Широковещательно передайте переменную только для чтения к кластеру

расширьте все на странице

Синтаксис

result = broadcast(sc,value)

Описание

result = broadcast(sc,value) широковещательно передает переменную value только для чтения к кластеру, инициализированному SparkContext sc.

Входные параметры

развернуть все

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

Введенный в R2017b

Документация MATLAB Compiler
Поддержка