Días

Función de transformación de particiones: una transformación para las marcas de tiempo y las fechas para dividir los datos en días. Soporta Spark Connect.

Advertencia

En desuso en la versión 4.0.0. En su lugar, use partitioning.days.

Syntax

from pyspark.sql import functions as dbf

dbf.days(col=<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.

Devoluciones

pyspark.sql.Column: datos particionados por días.

Examples

df.writeTo("catalog.db.table").partitionedBy(
    days("ts")
).createOrReplace()

Nota:

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