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 物件