我寫了下麵的代碼:
data =火花。sql(“選擇A_adjClose、AA_adjClose AAL_adjClose, AAP_adjClose, AAPL_adjClose deltabase。a_30min_delta deltabase。aa_30min_delta deltabase。aal_30min_delta deltabase。aap_30min_delta deltabase。aapl_30min_delta”) spark.conf.set (“spark.sql.execution.arrow。啟用”、“真實”)#這部分保持運行命令data_pd = data.toPandas () df_pct = data_pd.pct_change (1)
困在.toPandas()的代碼這部分。
data =火花。sql(“選擇A_adjClose、AA_adjClose AAL_adjClose, AAP_adjClose, AAPL_adjClose deltabase。a_30min_delta deltabase。aa_30min_delta deltabase。aal_30min_delta deltabase。aap_30min_delta deltabase。aapl_30min_delta”)顯示(數據)spark.conf.set (“spark.sql.execution.arrow。啟用”、“true”) data_pd = data.toPandas () # df_pct = data_pd.pct_change(1) #顯示(df_pct)
@Hubert杜德克我不認為問題是數據類型。
在我原來的代碼中,有一個日期/時間,但現在我調試。我意識到刪除日期/時間列並不能解決這個問題。
現在,數據類型的數據隻是浮動。
同時,我pct_change刪除。這個問題仍然存在。