apache-spark-sql

英文: Spark java DataFrame Date filter based on max Date another DataFrame 问题 我有两个数据框架 从一个数据框架中获取日期列的最...

英文: Spark sql registered temp table cannot be used in sqlContext.read()? 问题 我有以下的代码： Map<String, ...

英文: Update value in struct type column in java spark 问题 我希望能够在嵌套数据集中更新值。为此，我在Spark中创建了一个嵌套数据集，其架构结构如...

英文: How to write a spark dataframe tab delimited as a text file using java 问题 我有一个包含许多列的Spark Datase...

英文: Get a single column values as a flat list in Apache spark using java 问题 import org.apache.spark....

英文: Apache Spark + Java: "java.lang.AssertionError: assertion failed" in ExpressionEncoder...

英文: Number of partitions when creating a Spark dataframe 问题 问题已经在其他帖子中提出，但似乎我的问题不适用于它们之一。 我在本地模式下使用S...

英文: How can I query where column exists in another column? 问题 你可以使用Python中的Pandas库来完成这个任务。以下是一种方法： i...

英文: Spark Streaming - Accessing an array of custom case class objects in a Spark SQL dataframe 问题 在我...

英文: Exploding Nested Struct In Spark Dataframe having Different Schema 问题 我有一个 JSON，其具有以下模式： |-- Poo...