Skip to content Skip to sidebar Skip to footer
Showing posts with the label Apache Spark Sql

Cosine Similarity For Two Pyspark Dataframes

I have a PySpark DataFrame, df1, that looks like: CustomerID CustomerValue CustomerValue2 12 … Read more Cosine Similarity For Two Pyspark Dataframes

Pyspark 2.1: Importing Module With Udf's Breaks Hive Connectivity

I'm currently working with Spark 2.1 and have a main script that calls a helper module that con… Read more Pyspark 2.1: Importing Module With Udf's Breaks Hive Connectivity

Passing Array To Spark Lit Function

Let's say I have a numpy array a that contains the numbers 1-10: [1 2 3 4 5 6 7 8 9 10] I also … Read more Passing Array To Spark Lit Function

Compare Two Dataframes Pyspark

I'm trying to compare two data frames with have same number of columns i.e. 4 columns with id a… Read more Compare Two Dataframes Pyspark

Joining Dataframes With Same Coumn Name In Pyspark

I have two dataframe which has been readed from two csv files. +---+----------+-----------------+ |… Read more Joining Dataframes With Same Coumn Name In Pyspark

How To Read Csv File With Additional Comma In Quotes Using Pyspark?

I am having some troubles reading the following CSV data in UTF-16: FullName, FullLabel, Type TEST.… Read more How To Read Csv File With Additional Comma In Quotes Using Pyspark?

Spark: How To Transpose And Explode Columns With Nested Arrays

I applied an algorithm from the question below(in NOTE) to transpose and explode nested spark dataf… Read more Spark: How To Transpose And Explode Columns With Nested Arrays

Spark Dataframe In Python - Execution Stuck When Using Udfs

I have a spark job written in Python which is reading data from the CSV files using DataBricks CSV … Read more Spark Dataframe In Python - Execution Stuck When Using Udfs