Exponenta Banner

cogroup

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

Данные группы из RDDs совместное использование того же ключа

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

Синтаксис

result = cogroup(obj1,obj2,numPartitions)

Описание

result = cogroup(obj1,obj2,numPartitions) группирует данные из obj1 и obj2, которые совместно используют тот же ключ.

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

развернуть все

Первый вход RDD, заданный как объект RDD.

Второй вход RDD, заданный как объект RDD.

Количество разделов, чтобы создать, заданный как скалярное значение.

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

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

развернуть все

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

%% cogroup
x = sc.parallelize({ {'a',1}, {'b', 4} });
y = sc.parallelize({ {'a',2} });
z=x.cogroup(y);

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

|

Введенный в R2017b

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