exponenta event banner

карта

Класс: 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