карта

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

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

Синтаксис

result = map(obj,func,varargin)

Описание

result = map(obj,func,varargin) возвращает новый result RDD первым применением функционального 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();

Введенный в R2017b