scala 相关问题

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

健康检查gRPC未能实施

我正在查看 gadling-grpc,在本地计算机上运行 phiSgr 的示例不会有任何问题,但是当我在 GitLab 上运行 GrpcExample(示例中提供了本地服务器)时,我遇到了...

回答 1 投票 0

Intellij Idea 为现有 Java 项目添加 Scala 支持

Intellij Idea 为现有 Java 项目添加 Scala 支持。 只是不明白如何将 Scala 工作表添加到现有的 Java 项目中? 如果有 Scala REPL 或工作表就好了。 但是一个...

回答 2 投票 0

将 ADT 转换为使用递归方案

我有这个数据结构,我想引入递归方案,以便将元数据附加到节点: 密封特征模式[A]扩展产品,可序列化 密封特征集合[A]前...

回答 1 投票 0

scala upickle / ujson 中对 JSON null 的惯用处理

我是 Scala 新手,想学习解决常见问题的惯用方法,例如 Python 的 pythonic。我的问题是关于使用 upickle 读取 JSON 数据,其中 JSON 值包含 ...

回答 2 投票 0

PostgreSQL 演变:“PSQLException:致命:抱歉,已经有太多客户端了”

我正在尝试设置一个开发 PostgreSQL 服务器。它正在运行,我可以从命令行创建角色、表等。然而,当我尝试使用 Play 应用进化时,我得到以下结果......

回答 3 投票 0

Scala Spark Sample 和 SampleBy 具有相同的行为

我正在尝试在 Spark Dataframe 中执行分层采样,但 SampleBy 函数的行为(奇怪)与样本类似。 火花版本3.0.1 导入spark.implicits._ val 数据 = 序列...

回答 2 投票 0

如何将数据插入到具有更改架构的增量表中

在 databricks Scala 中,我正在分解 Map 列并将其加载到增量表中。我有一个增量表的预定义架构。 假设该模式有 4 个列 A、B、C、D。 所以,第一天我正在加载...

回答 1 投票 0

缓存和持久化何时执行(因为它们看起来不像操作)?

我正在实现一个spark应用程序,下面是一个示例片段(不完全相同的代码): val rdd1 = sc.textfile(HDFS_PATH) val rdd2 = rdd1.map(func) rdd2.persist(StorageLevel.MEMORY_AND...

回答 2 投票 0

如何创建具体化为 ActorRef 的 akka 源,其中传入消息知道发送者

val ref = Source.actorRef[String]( 完成匹配器 = PartialFunction.empty, failureMatcher = PartialFunction.empty, 100000, OverflowStrategy.dropNew ).to(Sink.foreachAsync(1){ ...

回答 1 投票 0

如何将 Array[Array[Array[Double]]] 导出到 scala 中的文件中?

我有一个代码需要很长时间才能计算 Array[Array[Array[Double]]],但我需要结果来计算具有不同参数但相同 Array[Array[Array[Double]]] 的其他内容是...

回答 2 投票 0

Scala 3 中的递归高阶函数类型

我想为一个函数定义一个类型,该函数执行某些操作,然后返回另一个相同类型的函数[可以是它本身]。明显的想法不起作用(“非法循环类型引用”

回答 1 投票 0

如何将List转换为LazyList?

如何使列表变得惰性,即在给定常规列表的情况下创建一个 LazyList?我试图在Scala文档中找到合适的方法,但没有这样的功能。

回答 2 投票 0

无法使用 mongodb 在 akka http 中将 scala.concurrent.impl.Promise$Transformation 转换为 scala.collection.immutable.Seq 错误?

基本上我尝试使用akka http从数据库获取数据。如果我直接在 api 中传递 (EmployeeRepo.findAll()) 那么它会显示所有数据,但是在使用 actor 时它会显示转换错误...... 这里的问题...

回答 2 投票 0

如何在 Spark 中从文本文件创建 DataFrame

我在 HDFS 上有一个文本文件,我想将其转换为 Spark 中的数据帧。 我正在使用 Spark 上下文加载文件,然后尝试从该文件生成各个列。 val myFile...

回答 9 投票 0

遍历 JSON 并在 Scala 中添加新字段

我有一个 JSON 结构,如下所示: { “A”: { “嵌套数组”:[ { “已经在这里2”:“x” }, { “已经在这里2”...

回答 1 投票 0

如何在 Slick 中获取组合 DBAction 的单独结果

我需要针对这种情况的帮助。 我必须在表 A 中插入多条记录,在表 B 中插入一条记录。我需要在单个事务中插入所有记录,但还需要为每个记录获取单独的结果

回答 1 投票 0

如何避免可空类型的模式匹配中出现“类型测试无法检查”的警告?

以下方法的目的是去除空值 def filterOutNulls[T](items: Iterable[T | Null]): Iterable[T] = items.collect { case 元素:T => 元素 } 该代码适用于

回答 1 投票 0

ClassNotFoundException。不同 Scala 版本有问题吗?

当我尝试运行这个.py时: 导入日志记录 从 cassandra.cluster 导入集群 从 pyspark.sql 导入 SparkSession 从 pyspark.sql.functions 导入 from_json, col 从 pyspark.sql.types 导入

回答 1 投票 0

Scala3 不会在 Intellij 中显示类型不匹配或格式错误

我正在使用 Scala 3.3.1,Intellij 没有给我有用的构建错误输出,也没有错误突出显示。 例如,如果我的项目使用任何 3.x Scala SDK,并且我有以下错误代码,...

回答 1 投票 0

在 columnSimilarties() Spark scala 之后获取列名称

我正在尝试使用spark中的columnSimilarities()构建基于项目的协同过滤模型。使用 columnsSimilarities() 后,我想将原始列名称分配回结果......

回答 1 投票 0

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