scala 相关问题

合并包含值数组的两列并在 scala 中创建一列？

我有一个具有两个数组列的数据框。我正在尝试通过将每个值 sep by 合并来将这两列合并为一列。例如，在下面的示例中，主题和标记应该合并并...

如何生成一个包含随机内容和N行的DataFrame？

如何在 Scala 中创建一个包含 100 行和 3 列且随机整数值在 (1, 100) 范围内的 Spark DataFrame？ 我知道如何手动创建 DataFrame，但无法自动化它： 瓦尔...

错误：scala：Scala 编译器库中没有“scala-library*.jar”

环境：Play 2.3.0/Scala 2.11.1/IntelliJ 13.1 我使用 Typesafe Activator 1.2.1 使用 Scala 2.11.1 创建一个新项目。项目创建后，我运行了 gen-idea。生成的IDEA程序...

使用 JDBC 创建与 Oracle DB 的 apache Spark 连接

我正在尝试使用 Apache Spark 和 scala 创建到我公司的 Oracle 测试服务器的连接。以下是我在 Spark-Shell 中运行的语句。我正在使用 JDK 8 并安装了适当的

从案例类的完全限定名称中获取案例类的引用，用于将数据帧转换为数据集

我有案例类的完全限定名称。对于运行时的用例，我需要获取用于将数据帧转换为数据集的案例类的引用。 例如。 我的 FQN 为：com.org.common。

如果我不返回 Mock，为什么返回类型是正确的？

我有这个特征，我根据需要在我的测试套件中混合： 特征 ValidationMock { def createValidationMock(结果: Either[Error, Unit] = Right(())): 验证 = { val validationMock = 模拟[

为什么start-all.sh从根本原因“无法启动org.apache.spark.deploy.master.Master：JAVA_HOME未设置”？

我正在尝试通过在cloudera Quickstart VM 5.3.0上运行的独立Spark服务来执行通过Scala IDE构建的Spark应用程序。 我的cloudera帐户JAVA_HOME是/usr/java/default

无法更新项目“120”的 Gitlab 提交状态：HTTP 403 Forbidden

在 jenkins 中，我在构建与 Gitlab 集成的任何项目时在 jenkins 控制台中看到以下错误消息。 无法更新项目“120”的 Gitlab 提交状态...

如何调用另一个 Scala 对象中的类？

我有一个 DFHelper 类，它有助于获取数据帧键。 我想将其维护为通用代码并从另一个主 scala 对象调用它。例如，我为通用定义的第一个代码部分

将 scala 数据帧中的值列表获取到变量中？

我有输入数据框。我想将可空列为空的路径键的值获取到变量中 val schema_json="""[{"orders":{"order_id":{"path&q...

如何从scala中的org.apache.spark.sql.Column类型获取键并放入列表变量中？

我正在尝试从 org.apache.spark.sql.Column 类型变量获取键并将其放入列表中，以便我可以进行一些模式比较。 inputFieldMap：org.apache.spark.sql.Column = 键：[自定义...

Scala 3 中 Union Type 和 Either 之间的隐式转换

我正在尝试从 Error | 类型开发一个隐式转换器。 A 在 Scala 3 中输入 Either[Error, A]。转换器的代码如下： 对象我的转换： 给定 unionTypeToEither[错误...

有没有办法“扁平化”貘模式

我有一个看起来像这样的通用结构： 特征 KeyType 扩展了 Product 案例类 DataBag[T <: KeyType]( key: T someData: String, someMoreData: String ) And a concrete

如何在scala中自动重新运行sbt项目

我创建了一个 sbt 项目来学习使用 akka-http 进行简单的增删改查操作。首先，我添加了简单的路线来检查它是否正常工作。 通过运行 sbt run 命令，我发现它在本地运行

如何切换工厂是否使用调试选项进行构建——从命令行

使用以下构建文件执行 mill run 将启动程序，暂停以供调试器连接，然后在调试器的控制下继续。 导入mill._，scalalib._ 对象 foo 扩展

ScalaFX 和猫效应

我正在尝试将 Cats Effect 集成到 ScalaFX 桌面应用程序中，但在执行任务时遇到问题。我想运行后台线程/光纤来初始化窗口...

如何将响应中的值写入加特林中的文件？

我有一个脚本，每次执行时都会创建新的referenceId。我用了 .check(正则表达式("订单。(.*?)\"").saveAs("referenceId"))) 提取referenceId。现在，我该如何将其写入/附加到...

scala、工厂构建工具和 IntelliJ 调试器

我正在编写 Scala 代码并使用 Mill 构建工具。我希望能够使用 IntelliJ 的调试器来调试我的代码，但无法说服它在断点处停止。 我已经设置了...

Traverse[IO]的实现在哪里

val foo: IO[List[Int]] = List(IO.pure(100)).sequence 在哪里可以找到序列方法的实现？我认为有一个针对 cats.effect.IO 的 Traverse 类型类实现，其中...

更新我们的一件制品后出现错误的符号引用错误

我将依赖项之一 gadling-config-library-ext 更新到了 3.10.2，这是我们公司工件中的最新版本，将 IntelliJ 中的项目 sdk 更新到了 JDK 17，我正在使用 Scala sdk 2.1...