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[])	返回由给定分区表达式分区的新 DataFrame ，使用 spark.sql.shuffle.partitions 作为分区数。

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[])

返回由给定分区表达式分区的新 DataFrame ，使用 spark.sql.shuffle.partitions 作为分区数。

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 对象