DataFrame.Repartition 方法

定義

重要

部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。

Repartition(Int32, Column[])	將指定資料分割運算式分割的新 `DataFrame` 傳回。 `numPartitions` 產生的 `DataFrame` 是雜湊分割。
Repartition(Int32)	傳回具有完全 `numPartitions` 分割的新 `DataFrame` 。
Repartition(Column[])	使用 `spark.sql.shuffle.partitions` 做為分割區數目，傳回由指定資料分割運算式分割的新 `DataFrame` 資料分割。

將指定資料分割運算式分割的新 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

資料分割數目

資料分割運算式

DataFrame 物件

傳回具有完全 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

資料分割數目

DataFrame 物件

使用 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

資料分割運算式

DataFrame 物件