DataFrame.RepartitionByRange メソッド

定義

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

RepartitionByRange(Column[])	パーティションの数としてを使用して`spark.sql.shuffle.partitions`、指定されたパーティション分割式によってパーティション分割された新しい `DataFrame` を返します。結果として得られるデータセットは、範囲がパーティション分割されます。
RepartitionByRange(Int32, Column[])	指定されたパーティション分割式によってパーティション分割された新しい `DataFrame` をに `numPartitions`返します。結果として得られる `DataFrame` 範囲はパーティション分割されます。

パーティションの数としてを使用してspark.sql.shuffle.partitions、指定されたパーティション分割式によってパーティション分割された新しい DataFrame を返します。結果として得られるデータセットは、範囲がパーティション分割されます。

public Microsoft.Spark.Sql.DataFrame RepartitionByRange (params Microsoft.Spark.Sql.Column[] partitionExprs);

member this.RepartitionByRange : Microsoft.Spark.Sql.Column[] -> Microsoft.Spark.Sql.DataFrame

Public Function RepartitionByRange (ParamArray partitionExprs As Column()) As DataFrame

パーティション分割式

DataFrame オブジェクト

指定されたパーティション分割式によってパーティション分割された新しい DataFrame をに numPartitions返します。結果として得られる DataFrame 範囲はパーティション分割されます。

public Microsoft.Spark.Sql.DataFrame RepartitionByRange (int numPartitions, params Microsoft.Spark.Sql.Column[] partitionExprs);

member this.RepartitionByRange : int * Microsoft.Spark.Sql.Column[] -> Microsoft.Spark.Sql.DataFrame

Public Function RepartitionByRange (numPartitions As Integer, ParamArray partitionExprs As Column()) As DataFrame

パーティションの数

パーティション分割式

DataFrame オブジェクト