Skip to content Skip to sidebar Skip to footer
Showing posts with the label Databricks

Pyspark Error With Udf: Py4j.py4jexception: Method __getnewargs__([]) Does Not Exist Error

I am trying to solve the following error (I am using the databricks platform and spark 2.0) tweets_… Read more Pyspark Error With Udf: Py4j.py4jexception: Method __getnewargs__([]) Does Not Exist Error

How To Read Parquet Files Under A Directory Using Pyspark?

I have searched online and the solutions provided online didn't resolve my issue. I am trying t… Read more How To Read Parquet Files Under A Directory Using Pyspark?

Perform A User Defined Function On A Column Of A Large Pyspark Dataframe Based On Some Columns Of Another Pyspark Dataframe On Databricks

My question is relevant to my previous one at How to efficiently join large pyspark dataframes and … Read more Perform A User Defined Function On A Column Of A Large Pyspark Dataframe Based On Some Columns Of Another Pyspark Dataframe On Databricks