“Geben Sie eine RDD zurück, die alle Elementpaare mit passenden Schlüssel in sich selbst und anderen enthält.” Code-Antworten

Geben Sie eine RDD zurück, die alle Elementpaare mit passenden Schlüssel in sich selbst und anderen enthält.

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))]