map

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

Верните новый RDD путем применения функции к каждому элементу входного RDD

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

Синтаксис

result = map(obj,func,varargin)

Описание

result = map(obj,func,varargin) возвращает новый RDD result при первом применении функции func ко всем элементам obj. varargin представляет список входных аргументов переменной длины для входов применяемой функции.

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

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

RDD входа, заданный как RDD объект.

Функция, применяемая к каждому элементу в вход RDD, заданная как указатель на функцию.

Типы данных: function_handle

Список входных аргументов переменной длины, задающий входы для применяемой функции.

Выходные аргументы

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

Конвейерный 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);

%% map
inputRDD = sc.parallelize({'A','B','C','A','B'},2);
redRDD= inputRDD.map(@(x)({x,1})).collect();

См. также

| | |

Введенный в R2016b

Документация MATLAB Compiler

Поддержка

Для просмотра документации необходимо авторизоваться на сайте