日

パーティション変換関数: タイムスタンプと日付を変換して、データを日ごとに分割します。Spark Connect をサポートします。

警告

4.0.0 では非推奨です。代わりにpartitioning.daysを使用してください。

構文

Python

from pyspark.databricks.sql import functions as dbf

dbf.days(col=<col>)

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または str	作業対象となる日付またはタイムスタンプの列。

戻り値

pyspark.sql.Column: 日ごとに分割されたデータ。

例

Python

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

注記

この関数は、DataFrameWriterV2 のpartitionedByメソッドと組み合わせてのみ使用できます。