DataFrame.Repartition Metoda

Reference

Definice

Obor názvů:: Microsoft.Spark.Sql

Sestavení:: Microsoft.Spark.dll

Balíček:: Microsoft.Spark v1.0.0

Důležité

Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.

Přetížení

Repartition(Int32, Column[])	Vrátí nový `DataFrame` oddíl danými výrazy dělení na `numPartitions`. Výsledná `DataFrame` hodnota hash je rozdělená na oddíly.
Repartition(Int32)	Vrátí nový `DataFrame` , který má přesně `numPartitions` oddíly.
Repartition(Column[])	Vrátí nový `DataFrame` oddíl podle zadaných výrazů dělení a použije `spark.sql.shuffle.partitions` se jako počet oddílů.

Repartition(Int32, Column[])

Vrátí nový DataFrame oddíl danými výrazy dělení na numPartitions. Výsledná DataFrame hodnota hash je rozdělená na oddíly.

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

Parametry

numPartitions: Int32

Počet oddílů

partitionExprs: Column[]

Dělení výrazů

Návraty

DataFrame

Objekt Datového rámce

Platí pro

Repartition(Int32)

Vrátí nový DataFrame , který má přesně numPartitions oddíly.

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

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

Public Function Repartition (numPartitions As Integer) As DataFrame

Parametry

numPartitions: Int32

Počet oddílů

Návraty

DataFrame

Objekt Datového rámce

Platí pro

Repartition(Column[])

Vrátí nový DataFrame oddíl podle zadaných výrazů dělení a použije spark.sql.shuffle.partitions se jako počet oddílů.

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

Parametry

partitionExprs: Column[]

Dělení výrazů

Návraty

DataFrame

Objekt Datového rámce

Platí pro