ヶ月

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

警告

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

構文

Python

from pyspark.databricks.sql import functions as dbf

dbf.months(col=<col>)

パラメーター

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

戻り値

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

例

Python

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

注記

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