Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
07-08-2022 08:51 PM
data = spark.sql (" SELECT A_adjClose, AA_adjClose, AAL_adjClose, AAP_adjClose, AAPL_adjClose FROM deltabase.a_30min_delta, deltabase.aa_30min_delta, deltabase.aal_30min_delta, deltabase.aap_30min_delta ,deltabase.aapl_30min_delta ")
display(data)
spark.conf.set("spark.sql.execution.arrow.enabled", "true")
data_pd = data.toPandas()
#df_pct = data_pd.pct_change(1)
#display(df_pct)@Hubert Dudek I don't think the problem is the data type.
In my original code, there was a date/time, but I am debugging now. And I realized removing the date/time column doesn't solve the problem.
Now, the data types of the data are just float.
Also, I removed pct_change. The problem still exists.