嗨
我有火花1.6.0 Cloudera 5.13.0
我也有同樣的問題,這是我的完整代碼,請幫助我
這是我排的格式:25 / 1月/ 2016:21:26:37 + 0100
從pyspark。sql進口HiveContext
從pyspark.sql。函數導入unix_timestamp坳
從pyspark.sql。類型進口TimestampType
從pyspark.sql。類型進口StringType
SQLContext = HiveContext (sc)
df = sqlContext。sql (“select * from test.test”)
df1 = df.select (unix_timestamp (df。date_hour, yyyy / MM / dd: HH: MM: ss”) .cast (TimestampType ()) .alias(“時間戳”))
df1.show ()
它仍然空