在写入期间 Spark repartiton、sortWithinParitions 和partitionBy 扰乱了我的排序
我有 scala Spark 代码，可将数据帧写入 csv 文件。代码如下所示 dataframe .select("path", "id", "top_path") .repartition(1, col("top_path")) .s…
- 共 1 页
- 1
我有 scala Spark 代码，可将数据帧写入 csv 文件。代码如下所示 dataframe .select("path", "id", "top_path") .repartition(1, col("top_path")) .s…
接受 或继续使用网站，即表示您同意使用 Cookies 和您的相关数据。