DataFrame.Repartition メソッド

定義

名前空間:

Microsoft.Spark.Sql

アセンブリ:

Microsoft.Spark.dll

パッケージ:

Microsoft.Spark v1.0.0

オーバーロード

Repartition(Int32, Column[])	指定したパーティション分割式によって にパーティション分割された新しい DataFrame を返します numPartitions。 結果 DataFrame はハッシュ パーティション分割されます。
Repartition(Int32)	パーティションが正確numPartitionsに含まれる新しい DataFrame を返します。
Repartition(Column[])	パーティションの数として を使用してspark.sql.shuffle.partitions、指定されたパーティション分割式によってパーティション分割された新しい DataFrame を返します。

Repartition(Int32, Column[])

指定したパーティション分割式によって にパーティション分割された新しい DataFrame を返します numPartitions。 結果 DataFrame はハッシュ パーティション分割されます。

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

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

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

パラメーター

numPartitions

Int32

パーティションの数

partitionExprs

Column[]

パーティション分割式

戻り値

DataFrame

DataFrame オブジェクト

Repartition(Int32)

パーティションが正確numPartitionsに含まれる新しい DataFrame を返します。

public Microsoft.Spark.Sql.DataFrame Repartition (int numPartitions);

member this.Repartition : int -> Microsoft.Spark.Sql.DataFrame

Public Function Repartition (numPartitions As Integer) As DataFrame

パラメーター

numPartitions

Int32

パーティションの数

戻り値

DataFrame

DataFrame オブジェクト

Repartition(Column[])

パーティションの数として を使用してspark.sql.shuffle.partitions、指定されたパーティション分割式によってパーティション分割された新しい DataFrame を返します。

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

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

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

パラメーター

partitionExprs

Column[]

パーティション分割式

戻り値

DataFrame

DataFrame オブジェクト