Stunden

Partitionstransformationsfunktion: Eine Transformation für Zeitstempel zum Partitionieren von Daten in Stunden. Unterstützt Spark Connect.

Warnung

Veraltet in 4.0.0. Verwenden Sie stattdessen partitioning.hours.

Syntax

from pyspark.databricks.sql import functions as dbf

dbf.hours(col=<col>)

Die Parameter

Parameter	Typ	Description
col	pyspark.sql.Column oder str	Zieldatums- oder Zeitstempelspalte, an der gearbeitet werden soll.

Rückkehr

pyspark.sql.Column: Daten partitioniert nach Stunden.

Examples

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

Hinweis

Diese Funktion kann nur in Kombination mit der partitionedBy Methode des DataFrameWriterV2 verwendet werden.