我有我的目录结构设置. src/main/scala/main/Main.scala src/main/scala/scripts/MainScript.scala 该脚本是将运行的后台作业. 我之前使用sbt-asse…
标签:scala
从Ubuntu终端运行scala * .jar文件
参见英文答案 > Increase JVM heap size for Scala?  …
scala – 如何使用封装的源和接收器测试akka流闭合形状可运行图
我创建了一个具有进程函数和传递给它的错误处理函数的akka流. Source和Sink完全封装在ClosedShape RunnableFlow中.我的意图是我将一个项目传递给父类并通过流程运行它.这一切似乎都有效,…
scala – 暂时禁用play框架中的缓存
我在 scala playframework 2.4应用程序中使用内置缓存. 在开发过程中,我希望能够暂时停用整个缓存. 我该怎么办? 最佳答案 如果您正在使用Play的默认缓存实现(即EhCache),则可以使用net…
scala – 为什么不能重载没有参数的方法,对于隐式类
我尝试在对象世界使用隐式中重载方法 世界级 class World { } object World { implicit class WithWorld(_world: World) { def world…
scala – 如何在Akka-Stream 2.0流程开始时向ActorRef发送消息?
目标是在连接客户端并启动流后发送WSConnectEvent.使用akka-streams 1.0,我能够通过以下方式实现此目的: Flow(Source.actorRef[WSResponseEvent](65535,…
如何使用Scala更新一个ORC Hive表格
我想更新一个orc格式的hive表,我可以从我的ambari hive视图更新,但无法从sacla(spark- shell)运行相同的更新语句 objHiveContext.sql(“select * from tab…
scala – IO Monad中未来的行为
我编写了一个返回IO值的函数: def foo(x : Int): IO[Future[Int]] = IO { // do some IO } 我正在使用Scalaz的IO类型类. 然后,我将其用于表达式,如下所示: …
scala – 加入多个rdds
我有4DD类型的RDD :((int,int,int),values)和我的rdds是 rdd1: ((a,b,c), value) rdd2:((a,d,e),valueA) rdd3:((f,b,g),valueB)…
scala – 将参数传递给SBT中的多个任务
在sbt 0.13.9中,我希望能够运行一个任务,该任务从命令行接收参数,然后将这些参数传递给另外两个任务. 我最初的尝试是这样的: lazy val logTask = InputKey[Unit](...) lazy…
如何在scala中检查我是否在运行时的@specialized函数或类中?
假设我有一个专门的类和一个相关的伴侣对象: trait Slice[@specialized +T] { ... override def equals(that :Any) = that match { case s …
scala – 模拟时间和Akka调度程序
我正在使用Akka构建多代理模拟,因此希望比实时更快地运行模拟.具体来说,我想配置Akka调度程序,以便调度程序从一个预定事件前进到下一个(显然可能涉及事件之间明显不同的时间步长),而不是通过一些基础固定时间步骤前进. …