scala 相关问题

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

Web 应用程序架构的功能性方法是什么样的?

P.S.例子是类似scala的,但语言并不重要,我对整体的函数式方法很感兴趣。 通常我看到这样的图案 外部世界 -> 控制器 -> serviceA -&...

回答 1 投票 0

查看使用 fs2 实现错误的 Doobie 查询结果

我想使用 htpp4s 将 Doobie 查询的结果作为 JSON 进行流式传输。核心问题是错误(如格式错误的查询)仅在 http4s 已发送

回答 1 投票 0

IntelliJ“无法推断 Scala 类路径...”但 Gradle testCompile 是正确的?

我有一个通过 Gradle 构建的 Spring Boot 项目,最近添加了一些加特林测试。 Gattings 的东西需要 Scala 支持,都在 src/test/scala 中。 构建。

回答 2 投票 0

猫效应3的Ref和AtomicCell有什么区别?

在 Cats Effect 3 中,它们提供了并发原语,如 Ref 和 AtomicCell。但我不确定两者之间有什么不同。 什么时候我们需要 AtomicCell 而不是 Ref?它们有什么特点?什么

回答 1 投票 0

如果状态列大于阈值,如何获取 Spark scala 数据框中的第一行

我有一个数据框,如下所示。我每小时从 HBase 表加载一次原始数据。如果状态等于1连续超过10分钟,那么我需要拿第一行......

回答 1 投票 0

Zio:获取资源时如何使用超时

我想做的是尝试从 TSemaphore 获取许可,但如果获取时间太长就会超时。 基本上是这样的: ZIO.acquireReleaseWith(semaphore.acquire.commit.timeoutFa...

回答 1 投票 0

为什么从 AWS Glue (Spark) 写入 kinesis 时出现“无法找到数据源”错误

我正在尝试从几个来源获取一些数据,对其进行一些转换,然后使用 AWSglue 和 scala 将其加载到 Kinesis 中。数据来自静态源,例如表和 s3 存储桶,所以...

回答 1 投票 0

deltaTable.generate("symlink_format_manifest") 不是增量

我正在使用Spark 2.4.5,Scala 2.11 我在 S3 上设置了一个增量表。在我的应用程序的每次运行中,都会生成并附加一个新的数据分区。 df 。写 .format("增量") .mo...

回答 1 投票 0

java.lang.RuntimeException:运行 `uname` 命令时出错

我按照这个在我的Java程序中使用pdal。 我在我的 pom 中添加了以下依赖项: io.pdal pdal-native 我正在按照 this 在我的 Java 程序中使用 pdal。 我在我的 pom 中添加了以下依赖项: <dependency> <groupId>io.pdal</groupId> <artifactId>pdal-native</artifactId> <version>2.7.0</version> </dependency> <dependency> <groupId>io.pdal</groupId> <artifactId>pdal_3</artifactId> <version>2.7.0</version> </dependency> <dependency> <groupId>io.pdal</groupId> <artifactId>pdal-scala_2.13</artifactId> <version>2.7.0</version> </dependency> 代码是: Pipeline pipeline = new Pipeline(json, LogLevel.Info()); //error on this line pipeline.execute(); 但这失败了: java.lang.RuntimeException:运行uname命令时出错 我不确定“uname”的来源。它不是我的管道 json 的一部分。 我错过了什么? 编辑: 这是堆栈跟踪: java.lang.RuntimeException: Error running `uname` command at scala.sys.package$.error(package.scala:27) ~[scala-library-2.13.13.jar:na] at com.github.sbt.jni.syntax.NativeLoader$.liftedTree1$1(NativeLoader.scala:21) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader$.loadPackaged$1(NativeLoader.scala:22) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader$.load$1(NativeLoader.scala:56) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader$.load(NativeLoader.scala:59) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader.<init>(NativeLoader.scala:6) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at io.pdal.Pipeline$.<init>(Pipeline.scala:50) ~[pdal_3-2.7.0.jar:2.7.0] at io.pdal.Pipeline$.<clinit>(Pipeline.scala:50) ~[pdal_3-2.7.0.jar:2.7.0] at io.pdal.Pipeline.<init>(Pipeline.scala:30) ~[pdal_3-2.7.0.jar:2.7.0] at io.pdal.Pipeline.<init>(Pipeline.scala:33) ~[pdal_3-2.7.0.jar:2.7.0] at com.lidarapidemo.lidarprocessing.LidarProcessor.streamPointCloudPostgis(LidarProcessor.java:100) ~[classes/:na] at com.lidarapidemo.controllers.LidarController.lambda$pointsInBoundingBox$0(LidarController.java:39) ~[classes/:na] at org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBodyReturnValueHandler$StreamingResponseBodyTask.call(StreamingResponseBodyReturnValueHandler.java:110) ~[spring-webmvc-6.1.11.jar:6.1.11] at org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBodyReturnValueHandler$StreamingResponseBodyTask.call(StreamingResponseBodyReturnValueHandler.java:97) ~[spring-webmvc-6.1.11.jar:6.1.11] at org.springframework.web.context.request.async.WebAsyncManager.lambda$startCallableProcessing$4(WebAsyncManager.java:348) ~[spring-web-6.1.11.jar:6.1.11] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[na:na] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[na:na] at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na] 2024-08-13T12:15:25.380+05:30 ERROR 2384 --- [lidarapidemo] [nio-8080-exec-3] o.a.c.c.C.[.[.[/].[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Async processing failed: java.lang.ExceptionInInitializerError] with root cause java.lang.RuntimeException: Error running `uname` command at scala.sys.package$.error(package.scala:27) ~[scala-library-2.13.13.jar:na] at com.github.sbt.jni.syntax.NativeLoader$.liftedTree1$1(NativeLoader.scala:21) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader$.loadPackaged$1(NativeLoader.scala:22) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader$.load$1(NativeLoader.scala:56) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader$.load(NativeLoader.scala:59) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at com.github.sbt.jni.syntax.NativeLoader.<init>(NativeLoader.scala:6) ~[sbt-jni-core_3-1.7.0.jar:1.7.0] at io.pdal.Pipeline$.<init>(Pipeline.scala:50) ~[pdal_3-2.7.0.jar:2.7.0] at io.pdal.Pipeline$.<clinit>(Pipeline.scala:50) ~[pdal_3-2.7.0.jar:2.7.0] at io.pdal.Pipeline.<init>(Pipeline.scala:30) ~[pdal_3-2.7.0.jar:2.7.0] at io.pdal.Pipeline.<init>(Pipeline.scala:33) ~[pdal_3-2.7.0.jar:2.7.0] at com.lidarapidemo.lidarprocessing.LidarProcessor.streamPointCloudPostgis(LidarProcessor.java:100) ~[classes/:na] at com.lidarapidemo.controllers.LidarController.lambda$pointsInBoundingBox$0(LidarController.java:39) ~[classes/:na] at org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBodyReturnValueHandler$StreamingResponseBodyTask.call(StreamingResponseBodyReturnValueHandler.java:110) ~[spring-webmvc-6.1.11.jar:6.1.11] at org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBodyReturnValueHandler$StreamingResponseBodyTask.call(StreamingResponseBodyReturnValueHandler.java:97) ~[spring-webmvc-6.1.11.jar:6.1.11] at org.springframework.web.context.request.async.WebAsyncManager.lambda$startCallableProcessing$4(WebAsyncManager.java:348) ~[spring-web-6.1.11.jar:6.1.11] at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[na:na] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[na:na] at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na] 总结评论:您正在使用的库对于您运行程序的操作系统不可行。 uname 是一个存在于 Unix 上的程序(因此也存在于 Linux 和 MacOS 上),但不存在于 Windows 上。 因此在 Windows 上运行您的程序预计会失败。

回答 1 投票 0

使用 circe 序列化不透明类型的最简单方法是什么

示例: 不透明类型 UserName = String 该版本自动序列化: 案例类 UserName(value: String) 扩展 AnyVal

回答 1 投票 0

是否可以使用随机索引列表直接覆盖 DenseMatrix 行的选定列

我正在尝试在 scala/breeze 中实现以下 python 代码: 将 numpy 导入为 np mat = np.random.normal(大小=(2, 5)) 印刷(垫) 索引 = np.random.choice(5, 替换 = False, 大小 = 3) 打印(我...

回答 1 投票 0

如何更改幺半群以选择endofunctor?

我想在 Option 的上下文中组合两个endofunctor。我想要的组合是通过 Category.compose 将两个 endofunctor 组合成一个。我发现 MonoidK[Endo].algebra[*] 实例

回答 1 投票 0

Spark Kinesis Stream Scala 示例尝试遵循 Spark 文档,但不产生输出

我正在尝试使用 Spark 流处理来自 Kinesis 流的数据。 我使用 https://spark.apache.org/docs/latest/streaming-kinesis-integration.html 作为编写代码的参考 对象 TimeAndLa...

回答 1 投票 0

org.apache.http.ContentTooLongException:实体内容对于配置的缓冲区限制 [104857600] 来说太长 [158924648]

我的服务执行弹性搜索查询时遇到附加错误。 这是错误日志: [错误] [ZScheduler-1] (Logs.scala:32) - 执行elasticSearch查询失败 com.sksamuel.elas...

回答 1 投票 0

如果运行时条件相同,如何让 Scala 或 Java JVM 删除分支?

比如我有这样的表情 if (DEBUG) log.debug("你好") scala或java中有没有一种方法可以以这种方式启动DEBUG变量,这样如果它是假的,整个表达式就是r...

回答 1 投票 0

我可以使用更高种类的类型作为参数来创建类的单个实例吗?

甚至很难简洁地表述问题并具有足够的描述性。我想为具有交集运算的集合创建一个半群实例。所以我正在尝试与编译进行通信...

回答 1 投票 0

playframework 2.8.8 - 类 sbt.internal.inc.MappedVirtualFile 无法转换为类 java.io.File

执行 sbt run 时出现此错误。 这是我可能相关的版本号。 播放框架 - 2.8.8 斯卡拉 - 2.13.6 sbt-1.5.5 java-11.0.13 addSbtPlugin("com.typesafe.sbt"...

回答 1 投票 0

Spark Dataframe na.fill 用于嵌套列

我正在尝试为 Spark 中具有空值的嵌套列设置默认值,但看起来 DataFrameNaFunctions.fill 函数不适用于嵌套列。 导入spark.implicits._ ...

回答 1 投票 0

Spark:替换嵌套列中的 Null 值

我想将以下数据框中的所有 n/a 值替换为未知。 它可以是标量或复杂的嵌套列。 如果它是 StructField 列,我可以循环遍历列并替换...

回答 4 投票 0

使用 Akka 的 Actor 进行异步消息处理

在我的项目中,我使用 Akka 的 Actors。根据定义,Actor 是线程安全的,这意味着在 Actor 的 receive 方法中 def 接收 = { 案例消息 => // 这里有一些逻辑 } 只有一个

回答 4 投票 0

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