【问题标题】:Spark intersection implementation火花交点实现
【发布时间】:2018-03-07 06:47:50
【问题描述】:

Spark如何实现交集方法?是否需要 2 个 RDD 共置在一台机器上?

来自here,它说它使用哈希表,这有点奇怪,因为它可能不可扩展,并且对两个 rdds 进行排序然后逐项比较可能提供了一个更具可扩展性的解决方案。

欢迎对这个主题提出任何想法

【问题讨论】:

  • 只是猜测实现:如果您有多个A 的子集,这样它们的并集就等于A,以及B 的多个子集; union(intersection(A1, B1), intersection(A2, B2), ... intersection(An, Bn)) 等于 intersection(A, B) 不是真的吗?如果这是真的,那么它可能就是这样工作的,即A1 和B1 只是A 和B 的分区/子集...

标签: apache-spark pyspark


【解决方案1】:

它绝对不需要将 RDD 放在一台机器上。您可以查看code 了解详情。看起来它使用了一个协同组。

【讨论】:

    猜你喜欢
    • 2018-04-20
    • 1970-01-01
    • 2015-11-06
    • 1970-01-01
    • 2015-08-07
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多