partitioning.days

Una transformación para las marcas de tiempo y las fechas para dividir los datos en días.

Nota:

Esta función solo se puede usar en combinación con el DataFrameWriterV2.partitionedBy método .

Syntax

from pyspark.sql.functions import partitioning

partitioning.days(col)

Parámetros

Parámetro	Tipo	Description
col	pyspark.sql.Column o str	Fecha de destino o columna de marca de tiempo en la que se va a trabajar.

Examples

from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
    partitioning.days("ts")
).createOrReplace()