メインコンテンツまでスキップ

パーティショニング.月

タイムスタンプと日付を変換してデータを月ごとに分割します。

注記

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

構文

Python
from pyspark.sql.functions import partitioning

partitioning.months(col)

パラメーター

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

例

Python
from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
    partitioning.months("ts")
).createOrReplace()

構文
パラメーター
例