Spark cogroup 函数

在 Spark 中，cogroup 函数对不同的数据集进行操作，例如 (K, V) 和 (K, W)，并返回一个 (K, (Iterable, Iterable)) 元组的数据集。此操作也称为 groupWith。

cogroup 函数的示例

在此示例中，我们执行 groupWith 操作。

• 要以 Scala 模式打开 Spark，请使用以下命令。

• 使用并行集合创建 RDD。

现在，我们可以使用以下命令读取生成的結果。

• 使用并行集合创建另一个 RDD。

现在，我们可以使用以下命令读取生成的結果。

• 应用 cogroup() 函数对值进行分组。

• 现在，我们可以使用以下命令读取生成的結果。

在这里，我们得到了期望的输出。