scala 相关问题

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

从 Scala 中的目录获取文件列表

我有一个目录“/local/dath/mi/”,其中包含许多文件 03_ssa_fruits.csv 03_ssa_can.csv 03_ssa_veg.csv sxattru.csv sxprod.csv sxstore.csv 我需要提取特定文件的列表...

回答 4 投票 0

如何比较两个共享相同内容的StructType?

看起来 StructType 保留了顺序,因此两个包含相同 StructField 的 StructType 不被认为是等效的。 例如: val st1 = 结构类型( StructField("ii",StringType,true) ::

回答 3 投票 0

在生产环境中部署时如何读取项目中的db.properties文件或任何其他conf文件......在scala Spark YARN HDFS中

在生产环境中部署时如何读取项目中的 db.properties 文件或任何其他 conf 文件......在 scala Spark Yarn HDFS 中...... 我收到这个错误... 2009 年 5 月 24 日 16:34:32 信息 客户: ...

回答 1 投票 0

在使用 Scala 插件 (2024.1.20) 的 IntelliJ(2024.1.1) 中,Main.main 失败并显示“无法找到或加载主类 org.public_domain.main”

更新: 经过进一步调查...这在 Scastie 中有效,表明这可能是 IntelliJ Scala 插件问题: https://scastie.scala-lang.org/sTH9lTwxTFOJJVT5ZP3bCA 创建新的 Scal 后...

回答 1 投票 0

如何使用 Jackson 解析 XML 并在 XML 中提取 CDATA

X Y/代号>... <?xml version="1.0" encoding="utf-8"?> <Product> <Object action="create"> <name>X</name> <codename>Y/codename> <external_id>YZ</external_id> <type>product</type> <Content variant="en"><![CDATA[{"elements": [ {"element": {"codename": "short_description_en"},"value": "XYZ"}, {"element": {"codename": "product_Standard"},"value": ""}, {"element": {"codename": "ISO" }, "value": [{"codename": "yes"}]}, {"element": {"codename": "material_type"},"value": [{"codename": "poly"}]}, {"element": {"codename": "product_number" }, "value": "1234"}, {"element": {"codename":"product_status" }, "value":[]} ]}]]></Content> </Object> </Product>""" 我尝试与 Jackson 一起整理 Xml 并提取值,但我无法找到提取 CDATA 字符串的解决方案。你能给我一个解决方案吗? 我尝试与 Jackson 一起整理 Xml 并提取值,但我无法找到提取 CDATA 字符串的解决方案。你能给我一个解决方案吗?

回答 1 投票 0

健康检查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

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