scala 相关问题

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

如何使用scala解压zip文件？

基本上我需要解压缩一个 .zip 文件，其中包含一个名为 modeled 的文件夹，该文件夹又包含许多 excel 文件。我很幸运地找到了已经编写的代码（ZipArch...

excel scala unzip

回答 7 投票 0

如果在 scala 中找不到列，如何使用模式文件读取输入 json 并填充默认值？

输入数据框 val input_json="""[{"orderid":"111","customers":{"customerId":"123"},"Offers":[{"Offerid":"...

scala apache-spark

回答 1 投票 0

Scala 案例类数量限制和 jvm 254 限制

新的 Scala 案例类数量限制是多少。在 scala 2.11 中，案例类的 22 个限制被删除。新的限制是多少？是否可以超出 jvm 限制 254 谢谢

java scala

回答 2 投票 0

部分应用函数的 Scala 组合

我希望能够从部分应用的函数组成函数。 IE。像这样的东西： def 平均值（数据：Seq[Option[Double]]）： Option[Double] = { val 数字 = data.flatten 数字

scala function composition

回答 1 投票 0

ScalaTest：BeforeAndAfter 未运行

我正在尝试学习如何在 ScalaTest 中使用固定装置设置和拆卸。我一直在尝试的一个例子如下：导入 org.scalatest._ 导入 scala.collection.mutable SampleTest 类...

scala testing scalatest

回答 3 投票 0

如何将字符串 json 转换为 scala 数据帧？

我有一个字符串 json，我正在尝试创建一个数据框。使用下面的代码我可以实现，但是我正在构建jar的环境，它抱怨toDS。有没有其他方法可以...

json scala apache-spark

回答 1 投票 0

如何在 Scala Dataframe 中的 Json 中填充缺失键的默认值？

我正在我的scala配置文件中读取json数据。我正在尝试提取客户 ID、位置、城市、州和状态（状态应位于地址键内）。由于状态是可选键，因此可能无法...

scala apache-spark

回答 1 投票 0

什么是<:< mean in Scala? [duplicate]

可能的重复：做什么<:<, <%<, and =:= mean in Scala 2.8, and where are they documented? e.g. in this example, from scala-arm 1.0: def toTraversable[B](implicit ev: R <:...

scala

回答 1 投票 0

将 Dataframe 转换为 scala 中的嵌套 Json

我有一个数据框，如下所示，用*1，*2这样构造每个级别的json..并且“->”显示父节点的子节点数据框.show 编号*1 姓名*1 电源*1 类型*1 配料1->id2 打顶...

json dataframe scala apache-spark

回答 1 投票 0

Await.result 总是挂起/超时并且从不返回结果（Scala - Akka 演员）

简而言之，我正在尝试制作一个计算斐波那契数的 Scala actor 系统。但是，Await.result() 行总是超时，我不确定问题是什么。 ...

scala akka actor

回答 1 投票 0

Spark Left Outer Join 会在不应该生成Optional.empty 时生成Optional.empty

我有一个包含节点对的 RDD，我需要为它们分配唯一的 id。但我遇到了 NPE，我不知道如何解决它。我基本上将所有节点放入一个不同的列表中......

java scala apache-spark left-join rdd

回答 1 投票 0

queryExecution.analyzed.stats.sizeInBytes 始终返回 9223372036854775807

我正在尝试检查我们在数据仓库中生成的不同表的大小，以便我们可以有一种自动方法来计算下次运行中的分区大小。为了得到桌子的尺寸...

scala apache-spark

回答 1 投票 0

org.apache.hadoop.fs.RawLocalFileSystem$DeprecatedRawLocalFileStatus 无法转换为 org.apache.spark.sql.execution.datasources.FileStatusWithMetadat

使用 scalaspark 创建增量表时出现以下错误。 _delta_log 正在仓库中创建，但在创建 _delta_log 后出现此错误线程异常...

java scala apache-spark delta-lake scala-spark

回答 1 投票 0

检查路径上是否存在增量表

我需要在加载之前从 delta-lake 表中删除某些数据。我可以从增量表中删除数据（如果存在），但当表不存在时会失败。 Databricks scala 代码...

scala databricks delta-lake

回答 3 投票 0

处理 Scala FS2 流转换流程中的异常

导入 cats.effect.{IO, IOApp} 导入 fs2.Pipe 导入 fs2.Stream 对象测试扩展 IOApp.Simple { 最终案例类 Student(id: Int, name: String) private val StudentData: 地图[Int, Student]...

scala scala-cats cats-effect fs2

回答 1 投票 0

创建 SparkSession 时如何修复 java.lang.InknownClassChangeError？

我在 IntelliJ 中运行项目时遇到此错误： “C:\Program Files\Java\jdk1.8.0_212 in\java.exe”... 连接到目标VM，地址：'127.0.0.1:57229'，传输：'socket'

java windows scala apache-spark

回答 1 投票 0

`rest*` 与 `rest @ _*`

val 列表（a，b，c，其余*）= ... val List(a, b, c, 剩余@_*) = ... 两者似乎都有效，但我遇到过前者引发错误“错误的简单模式”的情况。只是偶尔...

scala

回答 1 投票 0

如何将时间戳字符串转换为时间戳格式？

我正在尝试将时间戳字符串转换为时间戳。我正在使用下面的方法，但它返回 2024-03-18T00:00 但我想要这种 yyyy-MM-dd HH:mm:ss 的格式导入java.time._ 导入 java.time.f...