DataFrame.RepartitionByRange 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í

RepartitionByRange(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ů. Výsledná datová sada je rozdělená na oddíly.
RepartitionByRange(Int32, Column[])	Vrátí nový `DataFrame` oddíl danými výrazy dělení na `numPartitions`. Výsledná `DataFrame` oblast je rozdělená na oddíly.

RepartitionByRange(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ů. Výsledná datová sada je rozdělená na oddíly.

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

Parametry

partitionExprs: Column[]

Dělení výrazů

Návraty

DataFrame

Objekt Datového rámce

Platí pro

RepartitionByRange(Int32, Column[])

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

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