Exponenta 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
Поддержка