數據類型:
AAPL_Time:時間戳
AAPL_Close:浮動
原始數據:
AAPL_Time AAPL_Close 2015 - 05 - 11 t08:00:00.000 + 0000 29.0344 2015 - 05 - 11 t08:30:00.000 + 0000 29.0187 2015 - 05 - 11 t09:00:00.000 + 0000 29.0346 2015 - 05 - 11 t09:30:00.000 + 0000 28.763 2015 - 05 - 11 t10:00:00.000 + 0000 28.6768 2015 - 05 - 11 t10:30:00.000 + 0000 28.7464 2015 - 05 - 12 t12:30:00.000 + 0000 28.7915 2015 - 05 - 12 t13:00:00.000 + 0000 28.8763 2015 - 05 - 12 t13:30:00.000 + 0000 28.8316 2015 - 05 - 12 t14:00:00.000 + 0000 28.8418 2015 - 05 - 12 t14:30:00.000 28.7703 + 0000
我想提取數據
火花。sql(“選擇AAPL_Time AAPL_Close從aapl_table AAPL_Time之間“% 09:30:00%”和“% 16:30:00%”)
我想結果應該是這樣的:
AAPL_Time AAPL_Close 2015 - 05 - 11 t09:30:00.000 + 0000 28.763 2015 - 05 - 11 t10:00:00.000 + 0000 28.6768 2015 - 05 - 11 t10:30:00.000 + 0000 28.7464 2015 - 05 - 12 t12:30:00.000 + 0000 28.7915 2015 - 05 - 12 t13:00:00.000 + 0000 28.8763 2015 - 05 - 12 t13:30:00.000 + 0000 28.8316 2015 - 05 - 12 t14:00:00.000 + 0000 28.8418 2015 - 05 - 12 t14:30:00.000 28.7703 + 0000
然而,最後的結果是這樣的:
查詢沒有返回結果
誰能幫我嗎?
你好,也許你可以使用date_format函數和檢索字符串小時和分鍾
進口pyspark.sql。函數作為F aapl_table。過濾器(F.date_format (F。坳(“AAPL_Time”)、“HHmm”) .between (" 0930 ", " 1630 "))
這是pyspark的版本,如果你想在火花sql可以試一試
顯示器(火花。sql(“選擇Aapl_Time AApl_Close從aapl_table DATE_FORMAT (Aapl_Time, HHmm)之間的‘0930’和‘1630’”))
讓我知道如果它幫助。
你好,也許你可以使用date_format函數和檢索字符串小時和分鍾
進口pyspark.sql。函數作為F aapl_table。過濾器(F.date_format (F。坳(“AAPL_Time”)、“HHmm”) .between (" 0930 ", " 1630 "))
這是pyspark的版本,如果你想在火花sql可以試一試
顯示器(火花。sql(“選擇Aapl_Time AApl_Close從aapl_table DATE_FORMAT (Aapl_Time, HHmm)之間的‘0930’和‘1630’”))
讓我知道如果它幫助。