pyspark.sql.functions.unix_timestamp¶
-
pyspark.sql.functions。unix_timestamp( 時間戳:可選(ColumnOrName]=沒有一個,格式:str=“yyyy-MM-dd HH: mm: ss” )→pyspark.sql.column.Column¶ -
轉換時間字符串給定模式(“yyyy-MM-dd HH: mm: ss”,默認情況下)到Unix時間戳(以秒為單位),使用默認時區和默認語言環境,如果失敗返回null。
如果時間戳是沒有,那麼它返回當前時間戳。
例子
> > >火花。相依。集(“spark.sql.session.timeZone”,“美國/ Los_Angeles”)> > >time_df=火花。createDataFrame(((“2015-04-08”),(“dt”])> > >time_df。選擇(unix_timestamp(“dt”,“yyyy-MM-dd”)。別名(“unix_time”))。收集()(行(unix_time = 1428476400))> > >火花。相依。設置(“spark.sql.session.timeZone”)