Dagen

Partitietransformatiefunctie: Een transformatie voor tijdstempels en datums om gegevens in dagen te partitioneren. Ondersteunt Spark Connect.

Waarschuwing

Afgeschaft in 4.0.0. Gebruik in plaats daarvan partitioning.days.

Syntaxis

from pyspark.databricks.sql import functions as dbf

dbf.days(col=<col>)

Parameterwaarden

Kenmerk	Typologie	Description
col	pyspark.sql.Column of str	Doeldatum- of tijdstempelkolom waaraan moet worden gewerkt.

Retouren

pyspark.sql.Column: gegevens gepartitioneerd op dagen.

Voorbeelden

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

Opmerking

Deze functie kan alleen worden gebruikt in combinatie met de partitionedBy methode van de DataFrameWriterV2.