intersection

한 RDD와 다른 RDD의 교집합 반환

구문

result = intersection(obj1,obj2)


설명

result = intersection(obj1,obj2)는 obj1과 obj2의 교집합 요소를 반환합니다.

입력 인수

obj1 — 첫 번째 입력 RDD

RDD 객체

입력 RDD로, RDD 객체로 지정됩니다

obj2 — 두 번째 입력 RDD

RDD 객체

입력 RDD로, RDD 객체로 지정됩니다

출력 인수

result — 두 입력 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에 개발됨

참고 항목

subtract | union | collect | parallelize