英文: ST_WITHIN using Spark / Java 问题 I have the following dataframe: +-------------+-----------------...
st_geomfromtext assertion failed using spark java
英文: st_geomfromtext assertion failed using spark java 问题 When I run the following code: Dataset<R...
java.lang.RuntimeException: Unsupported literal type class org.apache.spark.sql.Dataset /Spark – JAVA
英文: java.lang.RuntimeException: Unsupported literal type class org.apache.spark.sql.Dataset /Spark -...
使用Apache Spark高效地计算多个配对的笛卡尔积。
英文: Taking the cartesian product over multiple pairs efficiently using Apache Spark 问题 ## Old contex...
将依赖的 JAR 包移至工作节点
英文: Move dependent jars to Worker Node 问题 我有一个Spark程序,其中还使用了一些外部的jar包。在编写程序后,通过Maven构建创建了一个jar包,然后将其...
在Java Spark中更新结构类型列中的值。
英文: Update value in struct type column in java spark 问题 我希望能够在嵌套数据集中更新值。为此,我在Spark中创建了一个嵌套数据集,其架构结构如...
从Kafka主题读取消息并将其转储到HDFS。
英文: Reading Message from Kafka Topic and Dump it into HDFS 问题 我试图从Kafka主题消费数据,将其加载到数据集中,然后在加载到HDFS之前...
数据处理在Spark中使用Java
英文: Data processing on spark using java 问题 我有一个 DataSet。 +-------------------+ | 日期 | +-------------...
Databricks Notebook Scala Spark Connect to MongoDB Could not initialize class com.mongodb.spark.config.ReadConfig$
英文: Databricks Notebook Scala Spark Connect to MongoDB Could not initialize class com.mongodb.spark....
如何在限制Kafka批次大小时使Spark Streaming在每个批次中进行提交?
英文: How to make spark streaming commit in each batch when limiting Kafka batch size? 问题 为了在使用Spark流处...
49