Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-spark-sql

How to relationalize a JSON to flat structure in AWS Glue

AnalysisException: It is not allowed to add database prefix

How to filter by date range in Spark SQL

How to drop columns and not rows using pandas axis equivalent in pyspark?

Split string in a spark dataframe column by regular expressions capturing groups

Can I get metadata of files reading by Spark

PySpark When item in list

Pyspark with Iceberg Catalog not found

Pyspark converting an array of struct into string

How to use outer apply in Spark sql

Create multiple Spark DataFrames from RDD based on some key value (pyspark)

How to create a map column with rolling window aggregates per each key

Groupby column and create lists for other columns, preserving order

Getting error like need struct type but got string in spark scala for simple struct type

Pyspark how to add row number in dataframe without changing the order?

How to add partitioning to existing Iceberg table

Collect only not null columns of each row to an array

Read data from Kafka and print to console with Spark Structured Sreaming in Python

Spark pivot invokes Job even though pivot is not an Action

which is faster spark.sql or df.filter("").select("") . using scala