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

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