scala

    2熱度

    2回答

    我有一個請求,其響應取決於actor的回覆。我想測試一下這種方式: val myActor:TestProbe = TestProbe() val route = new MyRoute() { override def myServiceActor:ActorRef = { myActor.ref } }.route "return a query re

    1熱度

    1回答

    的 :history 和 :h? 例如查看和搜索歷史REPL: scala> :h? req 19 :require /git/BIDMach/BIDMach.jar 20 :require /git/BIDMat/BIDMat.jar 21 :require /git/BIDMach_Spark/BIDMach_Spark.jar 27 :require /git/BIDMac

    0熱度

    1回答

    PlayFramework文檔顯示上傳文件非常簡單。 https://www.playframework.com/documentation/2.5.x/ScalaWS ws.url(url).post(Source(FilePart("hello", "hello.txt", Option("text/plain"), FileIO.fromFile(tmpFile)) :: DataPart(

    1熱度

    2回答

    如何在將take(5)調用到另一個RDD後將返回的集合轉換爲另一個RDD,以便我可以將輸出文件中的前5個記錄保存起來? 如果我使用saveAsTextfile它不讓我使用take和saveAsTextFile在一起(這就是爲什麼你看到該行在下面註釋)。它以排序順序存儲RDD中的所有記錄,因此前5個記錄是前5個國家,但我只想存儲前5個記錄 - 是否可以在RDD中轉換集合[take(5)]? val

    0熱度

    1回答

    我想解析字符串數據"2016-06-08T10:27:17.369000000000Z",與 import java.text.SimpleDateFormat import scala.util.Try object TimeParse extends App { val raw = "2016-06-08T10:27:17.369000000000Z" private

    0熱度

    2回答

    我的代碼基本上在Apache Spark上運行,其中每個容器都在單獨的JVM上運行。您爲容器指定了一定的內存限制。在我的程序中,一個容器完成了一項任務,但是當它試圖執行另一項任務時,它會崩潰,說超出了內存限制。如果我在單獨的容器中運行每個任務,它們總是運行良好。所以,看起來在任務完成後留下了一些未關閉的資源,我無法在代碼中找到它們,而這些未關閉的資源增加了容器的內存。所以,我的問題是,Java中有

    1熱度

    2回答

    for (i <- 0 to 1; c <- 0 until str.length) { print(c + i).toChar } for (i <- 0 to 1; c <- 0 until str.length) yield (str(c) + i).toChar 當我運行上面的第一個代碼片段時,出現錯誤:value toChar is not a member of U

    6熱度

    1回答

    我已經爲使用免費monad的ETL過程實現了一種簡單的語言。當使用List作爲數據讀取和存儲的輸入和輸出時,一切工作正常。不過我使用異步圖書館和Future[List] 常見的進口工作和定義 import scala.concurrent.Future import scala.concurrent.ExecutionContext.Implicits.global import cats.f

    0熱度

    2回答

    我得到recursive value foo needs type以下代碼: object Repro { private final case class Foo(bar: Boolean = false) def repro = { val foo = Foo(bar = true) val Foo(bar) = foo } } 然

    1熱度

    1回答

    package controllers import javax.inject._ import play.api._ import play.api.mvc._ import play.api.libs.json._ import play.api.libs.streams._ import akka.stream._ import akka.actor._ import ak