Search
 
SCRIPT & CODE EXAMPLE
 
CODE EXAMPLE FOR PYTHON

Return an RDD containing all pairs of elements with matching keys in self and other.

x = sc.parallelize([("a", 1), ("b", 4)])
y = sc.parallelize([("a", 2), ("a", 3)])
sorted(x.join(y).collect())
# [('a', (1, 2)), ('a', (1, 3))]
Source by spark.apache.org #
 
PREVIOUS NEXT
Tagged: #Return #RDD #pairs #elements #matching #keys
ADD COMMENT
Topic
Name
1+6 =