flatMapValues

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

Передайте каждое значение в паре "ключ-значение" RDD через flatMap метод без изменения клавиш

Синтаксис

result = flatMapValues(obj,func)

Описание

result = flatMapValues(obj,func) передает каждое значение в паре "ключ-значение" RDD obj через flatMap метод без изменения клавиш. func представляет функцию, которая будет применяться flatMap способ.

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

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

RDD входа, на который применяется функция преобразования, заданная как RDD объект.

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

Пример:

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

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

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

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

%% flatMapValues
inRDD = sc.parallelize({ {'AA', {1,2,3}}, {'BB',3}, {'CC', {'cc',4}} });
f = @(x)(x);
out = inRDD.flatMapValues(f).collect();
% out : {{'AA',1},{'AA',2},{'AA',3},{'BB',3},{'CC','cc'},{'CC',4}}

См. также

| | |

Введенный в R2016b