日付部分
日付/タイムスタンプまたは間隔ソースの一部を抽出します。
構文
Python
from pyspark.databricks.sql import functions as dbf
dbf.date_part(field=<field>, source=<source>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
| ソースのどの部分を抽出するかを選択します。サポートされる文字列値は、同等の関数 |
|
|
|
戻り値
pyspark.sql.Column: 日付/タイムスタンプまたは間隔ソースの一部。
例
Python
import datetime
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(datetime.datetime(2015, 4, 8, 13, 8, 15),)], ['ts'])
df.select(
'*',
dbf.date_part(dbf.lit('YEAR'), 'ts').alias('year'),
dbf.date_part(dbf.lit('month'), 'ts').alias('month'),
dbf.date_part(dbf.lit('WEEK'), 'ts').alias('week'),
dbf.date_part(dbf.lit('D'), df.ts).alias('day'),
dbf.date_part(dbf.lit('M'), df.ts).alias('minute'),
dbf.date_part(dbf.lit('S'), df.ts).alias('second')
).show()