Я хочу получить системную дату в pyspark. Я попробовал некоторый код, но он дает мне вчерашнюю дату. Можете ли вы помочь мне решить эту проблему?
код:
spark.sql("SELECT ID AS GRP_ID, DEV_NM AS GRP_NM, NAME, TYPE, from_utc_timestamp(current_timestamp(), 'EST5EDT') AS IM_INSERT_DT FROM vw_grp").show(2)
вывод:
+------------------+---------------+------------+---------+--------------------+
| GRP_ID| GRP_NM| NAME| TYPE| IM_INSERT_DT|
+------------------+---------------+------------+---------+--------------------+
|00G0B000002cpcjUAA| DM_ONC_Users|DM_ONC_Users| Regular|2020-01-16 23:58:...|
|00G0B000002cpoQUAQ|X105_30_5000035| null|Territory|2020-01-16 23:58:...|
+------------------+---------------+------------+---------+--------------------+
Я хочу сегодняшнюю дату: 2020-01-17 15:34: 15