scala

0热度

2回答

我有一系列参数。对于每个参数，我必须执行数据库查询，这可能会或可能不会返回结果。简单地说，我需要在第一个结果非空后停止。当然，我想避免不必要的电话。需要注意的是 - 我需要将此操作包含为另一个未来 - 或任何“最具反应性”的方法。说起代码： //that what I have def dbQuery(p:Param): Future[Option[Result]] = {} //my l

0热度

1回答

结合Kleisli使用套折

我使用的是Scala 2.11和Scalaz 7.2.3（最新版）。我在组合Kleisli时遇到了麻烦。我有两个功能： type A = ... type B = ... def set: Set[A] def f: A => Kleisli[scalaz.effect.IO, B, Unit] val result: Set[Kleisli[scalaz.effect.IO, B,

1热度

1回答

不能解析符号分裂火花工作

我跑在我的IntelliJ IDE火花应用程序作为Maven项目，我试图创建一个rowRDD并将其转换为数据帧并将其存储在HDFS。 SPARK版本：1.5.2 SCALA版本：2.10.4 我的代码： val rowRDD= dataframename.map(_.split("\t")).map(p => Row(p(0),p(1),p(2),p(3))) 据报道价值分裂是不是我的包类和

6热度

1回答

在Slick中导入不同的数据库驱动程序

Slick 3具有“导入API”以使用特定的数据库驱动程序。例如 import slick.driver.H2Driver.api._ ...DAO implementation... 或 import slick.driver.PostgresDriver.api._ ...DAO implementation... 我如何在单元测试中使用PostgreSQL在生产和h2？

-2热度

1回答

在Scala中使用关键字的目的是什么？

以下代码段中的using是什么意思？ case Event(Task1('name', num, categ), _) => goto(RunAll) using ToAdd(num, categ)

0热度

1回答

为什么我不能在Scala中为匿名函数指定结果类型？

编辑：找到答案，查看帖子结尾。不断收到错误，发现它是因为我试图将结果类型添加到lambdas。这是精细 (p: Int) => p 而 (p: Int): Int => p 导致其投诉。我很惊讶 - 为什么不允许它？毕竟我可变量指定类型（我已经为括号可读性型），如果我指定的λ： val f2: (Int => Int) = (p: Int) => p 但当时我还不如def它： def f2(p:

0热度

1回答

在Scala反射中，为什么TypeTag上的反射函数仍然具有类型擦除？

考虑下面的Scala程序： val arr: Seq[String] = Seq("abc", "def") val cls = arr.head.getClass println(cls) val ttg: TypeTag[Seq[String]] = typeOf[Seq[String]] val fns = ttg.tpe .members val fn = fns

2热度

1回答

如何在Scala中编写数据类型的简写

如何编写数据类型的简写？例如，。可以说，而不是List[Integer]，我宁愿键入Integers ，而不是这个 def processNumbers(input:List[Integer]):List[Integer] = ... 到 def processNumbers(input:Integers):Integers = ... 这可能吗？感谢

0热度

2回答

嵌套在特质中的类：价值是什么？

我一直在使用通常定义嵌套在特征中的类的Play Framework应用程序。这是一个设计简单的例子。服务/ UsefulServiceComponent.scala trait UsefulServiceComponent { val usefulService: UsefulService class UsefulService { def doSomethi

2热度

1回答

斯卡拉测试用火和忘记期货

所以我有一些端点服务器代码，在那里我想异步运行的东西。为此我使用期货。有迹象表明，导致结果的任务，但也有不昂贵的IO任务，所以我在火灾执行它们，忘记未来，像这样：那 import scala.concurrent.Future val ec = scala.concurrent.ExecutionContext.global Future { Thread.sleep(10000