1. ホーム
  2. python

[解決済み] DataFrameの現在のパーティション数を取得する

2023-04-12 12:43:08

質問

DataFrameの現在のパーティション数を取得する方法はあるのでしょうか? DataFrameのjavadoc(spark 1.6)を確認しましたが、そのようなメソッドは見つかりませんでしたが、私が見逃しているだけでしょうか? (JavaRDDの場合、getNumPartitions()メソッドがあります)。

どのように解決するのですか?

まず getNumPartitions() をDataFrameの基礎となるRDD上で、例えば df.rdd.getNumPartitions() . Scalaの場合、これはパラメータレスのメソッドです。 df.rdd.getNumPartitions .