pyspark.sql.functions.datepart ¶

datepart ( field : ColumnOrName , source : ColumnOrName ) → pyspark.sql.column.Column [source] ¶

提取日期/时间戳或时间间隔源的一部分。

None

版本 3.5.0 中的新功能。

Parameters

field 列 or str: 选择应该提取的源的哪个部分，支持的字符串值与等效函数 extract 的字段相同。
source 列 or str: 应从日期/时间戳或间隔列中提取 field 。

Returns

列: 日期/时间戳或区间源的一部分。

示例

           >>> import datetime
>>> df = spark.createDataFrame([(datetime.datetime(2015, 4, 8, 13, 8, 15),)], ['ts'])
>>> df.select(
...     datepart(lit('YEAR'), 'ts').alias('year'),
...     datepart(lit('month'), 'ts').alias('month'),
...     datepart(lit('WEEK'), 'ts').alias('week'),
...     datepart(lit('D'), 'ts').alias('day'),
...     datepart(lit('M'), 'ts').alias('minute'),
...     datepart(lit('S'), 'ts').alias('second')
... ).collect()
[Row(year=2015, month=4, week=15, day=8, minute=8, second=Decimal('15.000000'))]

          

pyspark.sql.functions.date_part

下一个

pyspark.sql.functions.每月天数