I need to use the
我需要使用
(rdd.)partitionBy(npartitions, custom_partitioner)
(rdd.)partitionBy(
阅读背景：
如何在pyspark中将DataFrame转换回普通RDD？
来源：互联网
分享到：
