Exponenta Banner
exponenta event banner

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}}

Смотрите также

| | |

Введенный в R2017b

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