Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- pandas_df=pd.read_excel(os.path.join(os.getcwd(),'pragya.xlsx'))
- spark_df = spark.createDataFrame(pandas_df)
- spark_df.write.mode("overwrite").saveAsTable("myDB.pragya_test")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement