DataFrame.RepartitionByRange Метод

Определение

Пространство имен:

Microsoft.Spark.Sql

Сборка:

Microsoft.Spark.dll

Пакет:

Microsoft.Spark v1.0.0

Перегрузки

RepartitionByRange(Column[])	Возвращает новое DataFrame секционирование по заданным выражениям секционирования, используя spark.sql.shuffle.partitions в качестве числа секций. Результирующий набор данных секционируется по диапазонам.
RepartitionByRange(Int32, Column[])	Возвращает новый DataFrame объект, секционированный заданными выражениями секционирования в numPartitions. Результирующий DataFrame объект секционируется по диапазону.

RepartitionByRange(Column[])

Возвращает новое DataFrame секционирование по заданным выражениям секционирования, используя spark.sql.shuffle.partitions в качестве числа секций. Результирующий набор данных секционируется по диапазонам.

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

Параметры

partitionExprs

Column[]

Секционирование выражений

Возвращаемое значение

DataFrame

Объект DataFrame

RepartitionByRange(Int32, Column[])

Возвращает новый 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

Параметры

numPartitions

Int32

Количество разделов

partitionExprs

Column[]

Секционирование выражений

Возвращаемое значение

DataFrame

Объект DataFrame