如何在 pyspark 中按列对数据帧进行分区以进行进一步处理?
How to partition dataframe by column in pyspark for further processing?
我需要按列对数据框进行分区。我知道可以保存在单独的文件中。但是我需要分区以便进一步处理(我需要按一定顺序对分区进行排序并将udf应用于有序分区)。
我的代码是:
df = spark.createDataFrame([(2,), (1,), (2,), (1,), (2,)], ("name",)) \
.repartitionByRange(2, "name") \
.rdd.glom().collect()
print(df)
# [[Row(name=2), Row(name=1), Row(name=2), Row(name=1), Row(name=2)], []]
我需要这样的东西:
[[(2,), (2,), (2,)], [(1,), (1,)]]
您可以使用 repartition
而不是 repartitionByRange
:
df = spark.createDataFrame([(2,), (1,), (2,), (1,), (2,)], ("name",)) \
.repartition(2, "name") \
.rdd.glom().collect()
print(df)
# [[Row(name=2), Row(name=2), Row(name=2)], [Row(name=1), Row(name=1)]]
repartitionByRange
使用抽样来估计范围,并且可能会导致您观察到的错误。
我需要按列对数据框进行分区。我知道可以保存在单独的文件中。但是我需要分区以便进一步处理(我需要按一定顺序对分区进行排序并将udf应用于有序分区)。
我的代码是:
df = spark.createDataFrame([(2,), (1,), (2,), (1,), (2,)], ("name",)) \
.repartitionByRange(2, "name") \
.rdd.glom().collect()
print(df)
# [[Row(name=2), Row(name=1), Row(name=2), Row(name=1), Row(name=2)], []]
我需要这样的东西:
[[(2,), (2,), (2,)], [(1,), (1,)]]
您可以使用 repartition
而不是 repartitionByRange
:
df = spark.createDataFrame([(2,), (1,), (2,), (1,), (2,)], ("name",)) \
.repartition(2, "name") \
.rdd.glom().collect()
print(df)
# [[Row(name=2), Row(name=2), Row(name=2)], [Row(name=1), Row(name=1)]]
repartitionByRange
使用抽样来估计范围,并且可能会导致您观察到的错误。