scala

    1热度

    1回答

    我不确定我想实现的是否可能。我所知道的是,我正从一个执行器访问单例对象,以确保它的构造器在每个执行器上只被调用一次。这种模式已经在我的代码库中被证明和按照预期用于类似的用例。 但是,我想知道的是,如果我可以在驱动程序初始化之后运送对象。在这种情况下, 访问ExecutorAccessedObject.y时,理想情况下它不会调用println,而是返回值。这是一个高度简化的版本,实际上,我想打电话给

    2热度

    2回答

    有没有人知道如何使用无形的测试工作。 package net.jtownson.swakka.jsonschema import org.scalatest.FlatSpec import org.scalatest.Matchers._ class OptionalFieldSpec extends FlatSpec { case class A(i: Int, j: Op

    2热度

    1回答

    这里是SBT的全新品牌,这可能是罪魁祸首。我试图让IntelliJ Community 2017.2导入我的a simple Scala/SBT project。 当您克隆该回购时,您可以(如果您需要)运行sbt compile和/或sbt run来验证小小的Driver.scala源码编译并按预期运行。 但是当我试图将其导入的IntelliJ: 糟糕!这是一个巨大的堆栈跟踪但结尾: [error

    0热度

    1回答

    在docs和here提供设置HostnameVerifierClass,我尝试使用下面的代码来改变HostnameVerifierClass: val sslConfig = AkkaSSLConfig().mapSettings { s => s.withHostnameVerifierClass(java.lang.Class[NoopHostnameVerifier])

    0热度

    1回答

    一个简单函数文本可以被写为 DEF添加(X:强度)= X + 2 在上述例子中我明白添加是一个函数,它接受一个I​​nt和给出一个Int。它的类型是add:(x:Int)Int 这很清楚。 但是下面的例子中,其是式期权[INT] =>内部是有点不清楚 scala> def matchFunction : Option[Int] => Int = { | case Some(x) => x

    -1热度

    1回答

    我是新的火花流,我不明白地图如何工作。我想从一个流排队一些问题后,我从一个构造函数,因此我写它传递的是: val data = inp.flatMap(_.split(",")) val points = data.map(_.toDouble) val queue: Queue[Point] = new Queue[Point] points.foreachRDD(rdd => { rd

    0热度

    1回答

    相关片段: case class Video( id: String, title: String, url: String, pictureUrl: String, publishedAt: Date, channel: String, duration: Option[String], createdOn: Date

    1热度

    3回答

    的disclude development.conf使用Scala的playframework 2.5, 我使用SBT插件PlayScala构建应用程序,装入瓶内, ,然后建立并推动一个泊坞窗图像使用sbt插件DockerPlugin 驻留在源代码存储库conf/development.conf(与application.conf相同)。 application.conf的最后一行说include

    0热度

    1回答

    当试图在多部分组成一个大文件上传到服务器chunked entity: val chunked = HttpEntity.Chunked.fromData(mimeType, sourceOfByteString) Multipart.FormData( Multipart.FormData.BodyPart("downloadPath", HttpEntity(fileResour

    0热度

    1回答

    我对Manifest和TypeTag有几个问题。我了解JVM不知道泛型并删除类型。所以,我不能这样做 def factoryForAll[T] = new T // will not compile. Runtime doesn't know what T is Scala编译器可以传送有关类型的信息使用Manifest运行时(现在已废弃)。 Manifest具有类似erasure的方法,其中