如何检查架构字段的类型为字符串数组
当前代码为： <pre><code>schema.field...
在Spark scakla中将groupBy和agg用于多个列
我有一个包含4列的DataFrame。我想基于2列应用<c...
循环使用相同架构的s3拼花文件路径序列，并保存在scala中的单个数据框中
给出了s3序列所需的内容。任何两个位置的区别是表的...
当相同的查询在Postgres上运行正常时，H2 SQL语法错误
我一直在使用slick进行数据库交互，并使用h2内存数据...
如何在Scala中使用动态键解析动态Json
我正在尝试解析本质上是动态的Json结构并将其加载到...
如何将Protobuf数据从Flink转发到Kafka和stdout？
我想在此处添加一些代码，并从Flink中输出protobuf数...
无法连接到Docker postgres容器-Scala
我创建了一个名为Job-board的服务，我希望它运行并与...
带有嵌套案例类的ReactiveMongo插入MongoDB
我有两个案例类 <pre><code>case class...
Spark数据帧没有利用工人
我有一个带有3个工作程序节点的Spark集群，当我尝试...
您如何指定/确定运行胖子罐所需的最低JDK？
我在一个有一些Java 14 jar的项目中使用了sbt-assem...
使用Scala将多行日志转换为JSON
我需要创建一个基于scala的转换，以将日志文件（以下...
是否可以通过代码设置联盟？
是否可以使用纯AMQP协议/标头设置联盟？现在，我正在...
尚未解决的SBT依赖项com.google.errorprone＃error_prone_annotations; [2.3.2,2.3.3]：找不到
我正在尝试通过sbt添加容易出错的依赖关系，并且在解...
在类型溢出期间，Spark无法将类型推断为更高的精度
我正在尝试类似的事情 <pre><code>val ...