英文: Spark UDF deserialization error from sample Java program 问题 这个示例直接来自于 Spark 示例代码,所以我有点不知道正在发生什么。...
Pyspark,在执行连接操作时执行程序失去了连接。
英文: Pyspark, executors lost connectivity when performing a join 问题 我使用的mesos-spark集群: 执行器在我尝试执行连接后的....
配置使用Maven和logback进行Apache Spark日志记录,并最终将消息传递到Loggly。
英文: Configuring Apache Spark Logging with Maven and logback and finally throwing message to Loggly 问...
HDFS文件编码转换器
英文: HDFS File Encoding Converter 问题 我正在尝试将一个HDFS文件从UTF-8转换为ISO-8859-1。 我编写了一个小的Java程序: String theInp...
如何在Java中转置一个Spark数据集?
英文: How to transpose a spark dataset in java? 问题 我是你的中文翻译,下面是你提供的内容的翻译: 我刚开始使用 Spark Java,想要转置数据集<...
无法使用Spark(sqlContext)将CSV数据写入AWS Redshift。
英文: Not able to write csv data in aws redshift using spark(sqlContext) 问题 java.io.InterruptedIOExcep...
spark-3.0.1-bin-hadoop2.7启动失败,java:没有该文件或目录
英文: spark-3.0.1-bin-hadoop2.7 failed to launch, java: No such file or directory 问题 在接触Java时,我遇到了一些问题...
在Spark数据集中根据一列分组后的示例数据。
英文: Sample data after grouping it based on a column in spark dataset 问题 我有一个格式为: Id 数据集 id1,[name1,n...
如何将复杂的Java类对象作为参数传递给Spark中的Scala UDF?
英文: How to pass complex Java Class Object as parameter to Scala UDF in Spark? 问题 我有一个Java客户端类(作为依赖Ja...
Spark Java: 在向量汇聚器中转义列名称中的点号
英文: Spark Java: Escape dot in column names for vector assembler 问题 我有一个数据集,其中一些列名带有点号。当涉及到向量装配器(Vect...
49