在Spark的窗口函数中添加新列
将小时分为15分钟，每15分钟的时间范围和相应的总和...
为什么测试用例抛出异常而不是发送JSON响应
我正在测试我的代码的这一部分，当接收到异常时，它...
将多个数组列拆分为行
这是一个与相同的问题 <a href="https://st...
使用Future和Async处理多个文件IO请求而不会阻塞
我是scala的新手，正在探索如何编写用于从文件读取的...
在Spark Scala中将CDT时间戳转换为UTC格式
我的数据框，myDF就像下面的波纹一样- <pre>&...
使用Scala提取嵌入式AWS Glue连接凭证
我有一个胶粘作业，可以直接从redshift读取数据，为...
有没有一种类似于在scala中跟随basepath用例的方法？
有人可以帮忙将以下代码转换为scala吗？ <pre>...
我到底如何使用Metals和VS Code调试器？
<a href="https://scalameta.org/metals/bl...
如何确定一个类是否是父类或特征的子类？
在Scala中，我们如何确定某个类是父类还是特征的子类...
具有数字范围类型的mkString行为
有没有办法使mkString与数字范围类型一起工作？ 我想...
Spark Mlib中的SelectKBest fclass_if替代
我正在尝试将代码从Python转换为Scala，我陷入了sci...
按数据框分组
我有一个数据框df，其中包含a，b，c，d，e，f，g列。...
将数据集[Dataset [Column]]展平为数据集[Column]
我正在尝试捕获数据库所有表的元数据。我正在使用&l...
在spark中的expr中添加列
用列值减去时间戳时，在expr中添加列。 df.withCol...