Как получить Системную дату в pyspark? - PullRequest
1 голос
/ 17 января 2020

Я хочу получить системную дату в 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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...