2017-09-21 7 views
1

spark sqlで列を選択するときにミリ秒の部分を削除したいと思います。timestamp spark sqlのミリ秒を削除する方法

例:2012年10月17日13:02:50.320

私は

spark.sql("select cast(datecol as timestamp) from table 
spark.sql("select unix_timestamp(datecol,"yyyy-MM-dd HH:mm:ss") from table 

を試した両動作していないようだ 13時02分50秒2012年10月17日として、私は結果が欲しいです、部分文字列は動作しますが、タイムスタンプ形式が必要です。他の方法がありますか?事前

答えて

1

おかげで、あなたのタイムスタンプ値が文字列であり、あなたがタイムスタンプにキャストされているので、あなたがSUBSTRING関数を使用して、それを試すことができます。

番目のオプション:

spark.sql("select from_unixtime(unix_timestamp(datecol, 'yyyy-MM-dd HH:mm:ss.SSS'),'yyyy-MM-dd HH:mm:ss') from table") 

あなたがエラーを取得している理由かもしれないこと、入力フォーマットを提供していませんでした。

私はこれがうまくいくと思います。

ありがとう、 マヌー

+0

ありがとうマヌー作品 – Babu

関連する問題