intersection

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

Верните заданное пересечение одного RDD с другим

Синтаксис

result = intersection(obj1,obj2)

Описание

result = intersection(obj1,obj2) возвращает элементы, которые являются заданным пересечением obj1 и obj2.

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

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

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

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

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

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

Конвейерный RDD, содержащий заданное пересечение двух входных 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);

%% intersection
x = sc.parallelize({'A','B','C'});
y = sc.parallelize({'B','D'});
z = sc.parallelize({'E','F'});
out1 = x.intersection(y).collect(); % {'B'}

См. также

| | |

Введенный в R2016b