Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-spark-sql

Regrouping / Concatenating DataFrame rows in Spark

Spark-HBASE Error java.lang.IllegalStateException: unread block data

Persisting data to DynamoDB using Apache Spark

Registering Hive Custom UDF with Spark (Spark SQL) 2.0.0

What is the use of queryExecution in spark dataframe?

Apache Spark UDF that returns dynamic data types

How to save bucketed DataFrame?

UDF to map words to term Index in Spark

how to change column value in spark sql

Kafka with Spark 2.1 Structured Streaming - cannot deserialize

How to cache partitioned dataset and use in multiple queries?

Cumulative distinct count with Spark SQL

Why is difference between sqlContext.read.load and sqlContext.read.text?

Error: Could not write class iw because it exceeds JVM code size limits. Method code too large

Scala: How to combine two data frames?

How to implement `except` in Apache Spark based on subset of columns?

How to cast an array of struct in a spark dataframe using selectExpr?

can't resolve ... given input columns

Spark DataFrame is Untyped vs DataFrame has schema?

Spark sampling options in JSON reader ignored?