scala 第4页 - IT屋-程序员软件开发技术分享社区

在Scala中使用超时的未来

假设我有一个函数，它调用一个阻塞的可中断操作。我想在超时的情况下异步运行它。也就是说，我想在超时到期时中断功能。所以我正在尝试这样做： import scala.util.Try import scala.concurrent.Future def launch(f: () => Unit, timeout: Int): Future[Try[Unit]] = { val a ..

发布时间：2022-08-14 12:00:12 scala concurrency future 其他开发

带有死信队列的Flink Scala贴图

我正在尝试创建一些Scala函数，以帮助Flinkmap和filter操作将其错误重定向到死信队列。然而，我正在努力解决Scala的类型擦除问题，这使我无法使它们成为泛型。下面mapWithDeadLetterQueue的实现未编译。 sealed trait ProcessingResult[T] case class ProcessingSuccess[T,U](result: ..

发布时间：2022-08-06 21:07:40 scala apache-flink flink-streaming 其他开发

构造函数不能实例化Slick Scala

我试图使用SLICK将查询从SQL转换为Scala代码，但在筛选子句中遇到编译器错误：构造函数无法实例化为预期类型。我的SLICK代码： val subquery = (for { pit ..

发布时间：2022-08-04 20:15:05 sql scala case slick 其他开发

Akka http-如何将ResponseEntity解包到CustomClass？

我正在使用Akka http向第三方API发出请求。响应是“APPLICATION/JSON”，我想使用Akka http将它们转换成一个定制的案例类。我想做这样的事情： val request = RequestBuilding.Get("https://service.com/v1/api/items") val response : Future[ItemsResponse] = h ..

发布时间：2022-08-03 17:23:32 scala akka unmarshalling akka-http 其他开发

Scala从数组返回质数

我是Scala的新手，所以对于这个非常基本的问题，我深表歉意。我在Liner上有一个很棒的功能，它可以检查一个数字是否为质数。我试图用它做的是，让函数接受一个数组，然后吐出质数。我如何才能最好地实现这一点？在单人班轮上也可以做到吗？谢谢！ def isPrime(num: Int): Boolean = (2 to num) forall (x => num % x != 0 ..

发布时间：2022-07-19 23:19:24 scala primes 其他开发

对可选参数建模的最佳方式

正如标题所说，在Scala中对可选参数建模的最佳方式是什么？对于可选参数，我指的是执行函数体时不需要的值。因为该参数存在默认值，或者该参数本身根本不需要(例如，配置或调试标志)；请注意，在Java上，我可能会将null传递给这些参数。这是Scala社区的常见问题解答，特别是新手制作的。例如：此处so：Implicit conversion from A to ..

发布时间：2022-07-19 11:30:56 scala design-patterns optional 其他开发

我正在尝试Kafka Streams的字数统计问题。我正在使用带有Scala版本2.11.12和SBT版本1.1.4的Kafka 1.1.0。我收到以下错误： Exception in thread "wordcount-application-d81ee069-9307-46f1-8e71-c9f777d2db64-StreamThread-1" java.lang.Unsatisfied ..

发布时间：2022-07-17 20:12:31 scala apache-kafka apache-kafka-streams rocksdb 其他开发

如何获得未来[序号[人]]而不是序号[未来[人]]

我有两个外部呼叫，这给了未来[序号[人物]] 它接受Person_id并将Person_Status返回为Future[字符串] 我需要使用第一次呼叫中可用的序列中的第二次呼叫来更新每个人的状态。这就是我如何尝试的， getFuturePeople.map( (seqPeople : Seq[People]) => { seqPeople.map(person => ..

发布时间：2022-07-17 15:32:23 scala future 其他开发

Build.sbt：如何添加Spark依赖项

您好，我正在尝试下载以下Build.sbt文件中的spark-core、spark-streaming、twitter4j和spark-streaming-twitter： name := "hello" version := "1.0" scalaVersion := "2.11.8" libraryDependencies += "org.apache.spark" %% "spa ..

发布时间：2022-07-03 18:41:34 scala apache-spark sbt spark-streaming 其他开发

通过Flink、Scala、addSource和ReadCsvFile读取CSV文件

我希望使用Flink、Scala-Language和addSource-以及ReadCsvFile-函数来读取CSV文件。我还没有找到任何关于这方面的简单例子。我只发现：https://github.com/dataArtisans/flink-training-exercises/blob/master/src/main/scala/com/dataartisans/flinktraining/ ..

发布时间：2022-07-01 12:34:34 scala csv apache-flink complex-event-processing 其他开发

为什么Scalavista看不到Build.sbt中设置的依赖关系？

Scalavista，或Scala语法(官方)-这些是我的Scala扩展。我有内置的.sbt例如 , "org.scalatra" %% "scalatra-json" % "latest.integration" 当我写的时候 import org.scalatra.json._ 然后将其标记为错误并显示object scalatra is not a membe ..

发布时间：2022-06-20 11:04:35 scala visual-studio-code sbt dependency-management 其他开发

Spark DataFrame需要将json文件作为一行中的一个对象吗？

我是Spark的新手，正在尝试使用Spark来读取这样的json文件。在ubuntu18.04、java1.8上使用Spark 2.3和Scala 2.11： cat my.json： { "Name":"A", "No_Of_Emp":1, "No_Of_Supervisors":2} { "Name":"B", "No_Of_Emp":2, "No_Of_Supervisors": ..

发布时间：2022-06-16 23:21:57 json scala apache-spark record corrupt 其他开发

如何在Spark DataFrame、Scala中将行转换为列

有没有办法将数据帧行转换成列。我有以下结构作为输入： val inputDF = Seq(("pid1","enc1", "bat"), ("pid1","enc2", ""), ("pid1","enc3", ""), ("pid3","enc1", "cat"), ..

发布时间：2022-06-11 18:30:47 scala apache-spark apache-spark-sql transpose 其他开发

Scala/Joda-Joda日期时间格式不适用

我想从数据库中检索日期并保留其格式。"20200406T145511.067Z"当我尝试将其解析为Joda日期时间时，格式更改为"2020-04-06T14:55:11.067+01:00"。由于这个问题，我试图显式地声明DateTimeFormat Joda DateTime应该返回为"yyyyMMdd'T'HHmmss.SSS'Z'"，但似乎并不适用。我希望以预期的格式返回DateTime对象 ..

发布时间：2022-05-29 23:53:39 scala datetime jodatime 其他开发

原因：java.lang.ClassNotFoundException：kinesis.DefaultSource

技术堆栈详细信息- Scala - 2.11.8 Spark - 2.4.4 Delta - 0.7.0 Running On - AWS EMR 用法- spark.readStream .format("kinesis") .option("streamName", kinesisConfs.streamName) .option("regi ..

发布时间：2022-05-25 18:15:58 scala apache-spark amazon-emr spark-structured-streaming amazon-kinesis 其他开发

火花作为蜂巢的执行引擎

Spark 2.4.2能否与Amazon EMR上的HIVE 2.3.4一起用作执行引擎？我已经通过以下命令将JAR文件链接到hive(scala-库、spark-core、spark-Common-network)： cd $HIVE_HOME/lib ln -s $SPARK_HOME/jars/spark-network-common_2.11-2.4.2.jar ln -s ..

发布时间：2022-05-25 17:58:20 scala apache-spark hadoop hive amazon-emr 其他开发

Spark：哪些选项可以与DataFrame.saveAsTable或DataFrameWriter.Options一起传递？

开发人员和API文档都没有任何关于DataFrame.saveAsTable或DataFrameWriter.options可以传递哪些选项的参考，它们会影响配置单元表的保存。我希望在这个问题的答案中，我们可以汇总一些信息，这些信息将有助于Spark开发人员更好地控制Spark保存表的方式，或许还能为改进Spark的文档提供基础。推荐答案您在任何地方都看不到options文 ..

发布时间：2022-05-11 21:18:32 scala hadoop apache-spark hive parquet 其他开发

使用AspectJ和Scala时出错

我正在尝试在IntelliJ上使用Scala和AspectJ作为IDE。#文件结构 Sample.scala-(包含Main方法的类) package sample class SampleClass { def printSample():Unit = println("hello") } object SampleObject extends App { val sam ..

发布时间：2022-05-08 23:59:32 scala intellij-idea aspectj 其他开发

在Scala中？=>；是什么意思？

我见过?=>符号出现在Scala代码和一些关于Scala 3的讨论文章中，所以我假设它是一个Scala 3+符号。在搜索文档或Google时什么也没有出现，但它看起来像Function类型的语法糖，所以它可能与类型和函数有关。这是什么意思？推荐答案类型(a: A, b: B, ..., z: Z) ?=> R基本上表示(using a: A, b: B, ..., z: Z) => ..

发布时间：2022-04-19 22:12:50 scala function types symbols scala-3 其他开发

Cloud SQL Postgres找不到适用于JDBC的驱动程序：postgres：//google/

提前谢谢！我是GCP新手，正在尝试使用Cloud SQL Postgres。我有一个已创建的数据库，并且希望使用Java或Scala在其中创建/更新/删除表。我正在尝试使用‘com.google.cloud.sql’包中的postgres-Socket-Factory。但在创建连接时，我收到一个错误， "java.sql.SQLException: No suitable ..

发布时间：2022-04-19 18:08:40 java postgresql scala google-cloud-platform google-cloud-sql Java开发

scala相关内容