scala 相关问题

Scala是一种通用编程语言,主要针对Java虚拟机。旨在以简洁,优雅和类型安全的方式表达通用编程模式,它融合了命令式和函数式编程风格。其主要特点是:具有类型推断的高级静态类型系统;功能类型;模式匹配;隐含参数和转换;运算符重载;与Java的完全互操作性;并发

如何比较 2 列的值并将输出放入 scala 的数组中

下面是输入数据框: 验证数据 = 序列( (5416,“伊尔”,“ar”,“17/02/2017”), (5416,“ar”,“我们”,“2017年2月22日”), (5416,“我们”,...

回答 1 投票 0

具有额外方法的匿名子类——scala2 与 scala3

以下代码在 scala2 中按我的预期工作,但在 scala3 中生成编译时错误。我试图在《Scala 编程》第五版和网络中找到解释,但失败了。任何在...

回答 1 投票 0

如何定义隐式“后备”?

考虑一个 Tapir.Codec 对象(这就是我遇到这个问题的方式,但我认为它与 Tapir 具体没有太大关系,它只是一般来说隐式解析优先级),它有一个

回答 2 投票 0

如何将 Spark Dataframe 转换为 JSONObject

我的目标是将 DataFrame 转换为 JSONObject 的有效 JSONArray。 我目前正在使用: val res = df.toJSON.collect() 但我得到了一个 Array[String] - JSON 转义字符串的数组,即: [...

回答 4 投票 0

Scala 等待 Future.sequence 的 Await.result,哪些 future 没有按时完成?

我有期货清单并等待 val listWithResult = Await.result(Future.sequence(listOfFutures), 10.分钟) 它失败了 java.util.concurrent.TimeoutException:期货在 [10 分钟后超时...

回答 1 投票 0

在 gadling scala maven 中设置环境变量无法从终端工作

我正在尝试从我的加特林项目的环境变量中读取一些值。但是当我执行maven命令时,没有设置环境值。它显示为空。 我试过 `mvn 加特林:

回答 1 投票 0

通过 Micrometer 公开 kafka 内部指标

我相信kafka客户端代码有各种内部指标。我正在考虑如何公开这些指标。我想公开内部指标,如何在 scala 中执行。 你能给我一个提示吗...

回答 1 投票 0

如何获取写入的记录数(使用DataFrameWriter的save操作)?

有没有办法获取使用spark保存记录时写入的记录数?虽然我知道它目前不在规范中,但我希望能够执行以下操作: val 计数 = df.write...

回答 3 投票 0

如何强制加特林使用内容类型标头?

我正在使用 Gadling 来测试一些遗留应用程序的性能。 Gattle 允许用户配置 http 请求,并且允许在不同的请求上重复使用部分配置。要做到这一点...

回答 1 投票 0

在Scala中创建临时资源测试文件

我目前正在为一个函数编写测试,该函数采用文件路径并从中加载数据集。我无法更改该功能。目前为了测试它,我正在为每次运行创建文件...

回答 1 投票 0

请求处理中如何获取HandlerAspect的`CtxOut`类型的值

在 zio-http 中,可以选择编写围绕请求提供某种上下文的中间件;作为一个具体的例子,我们可能会想到一个 auth 中间件来查找某些 ses 包...

回答 1 投票 0

在spark中使用postgres函数

在将数据帧写入 postgresql 时如何使用 pgp_sym_encrypt ? 当我这样做时: val df_encr = df.withColumn("加密_col", expr("pgp_sym_encrypt('加密_col_pg,'...

回答 1 投票 0

在宏生成期间获取类型的隐式值

宏根据隐式提供的所有属性值生成案例类的空实例。 解决方案的当前状态可以在 GH 上找到: https://github.com/atais/empty/blob/

回答 1 投票 0

Akka持久化创建新的DB连接池

我有akka微服务,对于数据库我使用如下配置: 公司名称.db { 配置文件=“slick.jdbc.MySQLProfile$” D b { 驱动程序=“org.mariadb.jdbc.Driver” url = "jdbc:我的...

回答 1 投票 0

为什么使用变量会使偏函数变得不那么偏?

我不明白为什么使用变量作为临时值会使部分函数不同: val f1: PartialFunction[Option[Int], Int] = { b => val i = 身份(b) 我匹配{ 卡斯...

回答 1 投票 0

简介 Scala3 编译器

我们有一个使用宏的 Scala3 项目。我们使用 Visual Studio Code 和 Metals 插件。 sbt 干净编译 花了20多分钟。有什么方法可以分析 Scala3 编译器来弄清楚...

回答 1 投票 0

理解Scala 3.3.1中Tuple2类的继承层次结构

我希望更清楚地理解 Scala 3.3.1 中 Tuple2 类的位置。 在其源代码中,可以清楚地看出该类继承了 Product2 特征。我仍然怀疑的是它是如何...

回答 1 投票 0

如何进行可取消的超时回调?

我希望用户可以运行带有回调的计时器并能够取消它。像这样的东西: def main: F[单位] = 为了 取消 <- runTimer(callback, 5.seconds) shouldCancel <- askU...

回答 1 投票 0

Scala 播放框架 - 使用组织 CA 使用 .JKS 文件将 Rest API 转换为 HTTPS

目前我正在运行 scala play 应用程序,现在它的 HTTP API 在我的本地 Angular UI 应用程序中运行良好。但在我们的组织中,为了更高的环境,我们需要将其转换为 SSL ...

回答 1 投票 0

如何将DenseVector转换为DenseMatrix

我有 N 行 xM 行 DenseVector[DenseVector[Double]] (或 DenseMatrix[DenseMatrix[Double]])的数据,并希望将此对象转换为 NxM 的 DenseMatrix 对象 密集向量(密集向量(1.0, 2...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.