pyspark.sql.functions.from_utc_timestamp

pyspark.sql.functions。 from_utc_timestamp ( 時間戳:ColumnOrName,tz:ColumnOrName )→pyspark.sql.column.Column

這是一種常見的函數數據庫支持沒有時區的時間戳。timezone-agnostic這個函數需要一個時間戳,並在UTC時間戳來解釋它,和呈現時間戳作為給定的時區的時間戳。

然而,時間戳在火花代表數微秒的Unix紀元,這不是timezone-agnostic。所以在火花這個函數僅僅轉變從UTC時間戳值給定的時區的時區。

這個函數可以返回令人困惑的結果與時區如果輸入是一個字符串,例如“2018 - 03 - 13 - t06:18:23 + 00:00”。原因在於,火花首先把字符串根據時區的時間戳字符串,最後顯示結果通過將時間戳轉換為字符串根據會話當地時區。

參數

時間戳 列或str

包含時間戳列

tz 列或str

一係列詳細的時區ID輸入應該調整。它應該在的格式提出區域id或區域補償。區域id必須形成“區域/城市”,如“美國/ Los_Angeles”。區補償一定的格式(+ | -)HH: mm的,例如“喂飼”或“+ 01:00”。還支持“UTC”和“Z”作為“+ 00:00”的別名。其他短名稱不推薦使用,因為他們可以模糊。

tz可以列包含時區ID字符串。

例子

> > >df=火花。createDataFrame(((“1997-02-28 10:30:00”,“JST”)),(“t”,' tz '])> > >df。選擇(from_utc_timestamp(df。ts,“太平洋標準時間”)。別名(“local_time”))。收集()(行(local_time = datetime。datetime(1997 2, 28歲,2、30))> > >df。選擇(from_utc_timestamp(df。ts,df。tz)。別名(“local_time”))。收集()(行(local_time = datetime。datetime(30) 1997、2、28日19日)

以前的

pyspark.sql.functions.trunc

下一個

pyspark.sql.functions.to_utc_timestamp