Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
07-02-2022 04:27 AM
I wrote the following code:
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 ")
spark.conf.set("spark.sql.execution.arrow.enabled", "true")
#This part keeps running command
data_pd = data.toPandas()
df_pct = data_pd.pct_change(1)
The code stucks in .toPandas() this part.
Labels:
- Labels:
-
Apache spark
-
Delta lake table
-
This