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

Для просмотра документации необходимо авторизоваться на сайте