scala 相关问题

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

Iceberg 的 FlinkSink 不会更新流写入中的元数据文件

我一直在尝试使用Iceberg的FlinkSink来消费数据并写入sink。我成功地从 kinesis 获取数据，并且我看到数据正在写入适当的

scala apache-flink flink-streaming apache-iceberg

回答 1 投票 0

将 Flink DataStream 写入 Iceberg 表：NoSuchMethodError: org.apache.parquet.schema.Types$PrimitiveBuilder.as

我尝试将flink数据流写入冰山表，如下所示： val kafkaStream = new KafkaDataSource(参数, new PacketSchema).getStream(env) val dataStream = kafkaStream.flatMap(new NullPacket...

scala apache-flink parquet apache-iceberg

回答 1 投票 0

从案例类中获取字段名称列表

我只需要获取案例类的字段名称。我对它的价值观不感兴趣。我认为 getClass.getDeclaredFields.map(_.getName) 会返回字段名称列表。 scala> 案例类用户（id...

scala

回答 8 投票 0

Scala3：通过元编程创建类型？

我正在使用 scala3 进行编码，利用编程结构类型。结构类型恰好模仿现有的案例类：他们的定义是纯粹的样板，因此，手工制作的诱惑......

scala metaprogramming scala-macros scala-3

回答 3 投票 0

通过PureConfig和Enumeratum实现包含Enum Map的Config类

我正在尝试使用 pureconfig 和 pureconfig-enumeratum 库版本 0.14.0 和

scala config pureconfig enumeratum

回答 2 投票 0

在 Spark Scala 中对聚合内的数组列进行过滤和求和

这感觉像是一个基本问题，但我在这里。我有两个有序列表列，我想过滤它们的值组合，然后计算我作为聚合得到的出现次数...

arrays scala aggregate filtering aggregate-functions

回答 1 投票 0

ZIO 测试 TestAspect：避免 @@ 所有测试

在此示例代码中，我有 2 个 Spec，我想对它们执行一些操作，然后我必须调用 @@ TestAspect.before 来进行这两个测试。如果测试数量增加，添加@@ TestAspect t...

scala zio zio-test

回答 1 投票 0

将 jar 文件发布到 GitLab 包存储库

我有一个 scala 项目，使用 SBT 我能够从中生成一个 jar 文件。我的下一个挑战是将生成的 jar 文件发布到 Gitlab 的包存储库中，以便我可以引用它......

scala maven jar gitlab

回答 2 投票 0

将 Scala 3 中的迭代器列表转换为列表迭代器

哎呀！我正在学习 Scala，并正在阅读《Scala 函数式编程》一书。我一直在玩，发现自己处于这样的情况：我希望能够转动

scala functional-programming monads scala-3

回答 1 投票 0

当模式与类的泛型参数匹配时，模式类型不兼容

为什么类的泛型构造函数参数的模式匹配失败，而方法的泛型参数的模式匹配成功？我有一个类型类 Ev：密封性状 Ev[T] 案例对象 EvInt 扩展 E...

scala generics

回答 1 投票 0

Akka Streams：如何使用 GraphDSL 构建源中源？

这是一个简单的场景。让我们从单个 Akka 源开始：比方说，从数据库检索的行。基于分区函数，不同的行需要被转移到不同的...

scala akka akka-stream alpakka

回答 2 投票 0

将 OpenCV 库链接到 Scala 项目

我一直在尝试运行一个使用 OpenCV 库的 Scala 项目。我正在使用 Maven 构建项目，在 pom.xml 文件中我有以下依赖项：我一直在尝试运行一个使用 OpenCV 库的 Scala 项目。我正在使用 Maven 构建项目，在 pom.xml 文件中我有以下依赖项： <dependency> <groupId>org.openpnp</groupId> <artifactId>opencv</artifactId> <version>4.9.0</version> </dependency> 在代码中我还包含以下行： System.loadLibrary(Core.NATIVE_LIBRARY_NAME) 但是当我运行该项目时，出现以下错误： Exception in thread "main" java.lang.UnsatisfiedLinkError: no opencv_java490 in java.library.path 另外，我尝试运行的应用程序使用 Spark，我想知道是否有必要在集群的每个节点上加载库，或者一旦加载到主节点中，不同的节点将能够使用 OpenCV 类实施。如果这个问题可能很愚蠢，我很抱歉，我一直在尝试自己寻找解决方案，但我缺乏知识使我无法理解真正的问题是什么。感谢任何愿意努力回答的人，如果您也能解释问题，我将非常感激。请注意，我已经尝试通过构建一个胖罐子（带有依赖项的罐子）来解决该问题，但我仍然遇到相同的错误。我一直在尝试寻找解决方案，据我了解，问题可能是 OpenCV 库不在我正在使用的系统中。事实上，我读到人们建议使用绝对路径链接库： System.loadLibrary("path/to/library.so") 我一直在尝试查找预编译的 .so 文件，但找不到（我无法在我正在使用的计算机上使用 cmake，因为我通过 ssh 连接并且没有下载工具的权限）。我正在考虑在本地计算机上编译源代码，然后将文件传输到远程计算机，但是，正如您可能已经理解的那样，此时我不确定我在做什么。编辑：在 @dmytro-mitin 的建议之后，我能够修复之前的错误。但现在我发现添加 System.loadLibrary(Core.NATIVE_LIBRARY_NAME) 并没有解决我之前遇到的运行时错误，即： Caused by: java.lang.UnsatisfiedLinkError: org.opencv.core.Mat.n_Mat()J 您是否考虑过通过 JavaCV 包装器项目使用 OpenCV？ https://github.com/bytedeco/javacv 在 build.sbt 文件中，您可以执行以下操作： libraryDependencies += "org.bytedeco" % "javacv-platform" % "1.5.9", 起初我认为这并不重要，所以我没有提及它，但我正在使用 Apache Spark 将应用程序分发到不同的节点上。问题是，虽然可以在主节点上找到库，但每个笔记都无法找到 OpenCV 的实现。我添加了以下几行： nu.pattern.OpenCV.loadShared() System.loadLibrary(org.opencv.core.Core.NATIVE_LIBRARY_NAME) 在映射到不同节点的函数中，现在它可以工作了。

scala opencv dynamic-library

回答 2 投票 0

Scala 中选项模式匹配何时优化至 if 语句？

这是 Option 的 ifA 函数，使用 if 语句编写： def ifA[A](fcond: 选项[布尔值])(ifTrue: 选项[A], ifFalse: 选项[A]): 选项[A] = if (fcond.isDefined) { 如果 (fcond.get) ...

scala optimization compilation pattern-matching bytecode

回答 1 投票 0

IntelliJ IDEA + Scala：如何轻松导航到损坏的测试

我在 Scala 测试中有这样的构造：类 ExpressionsTest 扩展 AnyFunSpec { 描述（“简单文字”）{ 描述（“有效”）{ 它（“123”）{ ...

scala intellij-idea scalatest

回答 1 投票 0

Spark：用spark绘制模型的学习曲线

我正在使用 Spark，我想训练一个机器学习模型。由于结果不好，我想显示模型在训练的每个时期所犯的错误（在训练和测试数据上......