Uur

Partitietransformatiefunctie: Een transformatie voor tijdstempels om gegevens in uren te partitioneren. Ondersteunt Spark Connect.

Waarschuwing

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

Syntaxis

from pyspark.databricks.sql import functions as dbf

dbf.hours(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 uren.

Voorbeelden

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

Opmerking

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