scala

0熱度

2回答

當我嘗試推出SBT，我得到以下信息： ~(501)$sbt (standard_in) 1: parse error No java installations was detected. Please go to http://www.java.com/getjava/ and download 然而，Java和斯卡拉安裝 ~(508)$java -version java ver

1熱度

1回答

火花sbt與graphx

我是新來的scala和sbt的東西，所以我不知道爲什麼我得到的錯誤。，以下是我build.sbt name := "graphx-example" version := "1.0" scalaVersion := "2.11.8" libraryDependencies ++= Seq( "com.typesafe" % "config" % "1.3.1", "o

0熱度

1回答

如何在構建Akka Streams Kafka中的ProducerMessage時配置偏移參數？

我正在使用Scala 2.11和Akka Streams Kafka 0.17。我有一個流其中：甲Source使用Source.actorRef創建。在這裏，演員計劃以固定間隔運行並持續生成消息，並將消息發送到流中。我已附加Producer作爲Flow。製片人推動ProducerMessage.Message成爲卡夫卡話題。一些數據庫操作。我有一個問題，同時構建ProducerMessa

0熱度

1回答

使用akka流時的事件順序

閱讀akka流的文檔，我不太清楚諸如消息順序之類的東西，以及我是否可以執行它。讓我用我爲聊天服務器編寫的一小段代碼來設置我的問題的上下文。 def flowShape(user: User) = GraphDSL .create(Source.actorRef[ChatMessage](bufferSize = 5, OverflowStrategy.fail)) { impl

0熱度

2回答

火花從一個小文件

查找我做的火花項目和需要就如何解決的最佳方式如下問題：我有一個數據幀（說MainDF），其中有上百萬的記錄。格式是這樣的（name：String，value：Int）。下面的內容例如： Davi,130 Joel,20 Emma,500 我還有一個小文件，與4號線的記錄，像這樣（的className：字符串，minValue（最小值）：詮釋，包括maxValue：智力）現在我需要創建通

1熱度

2回答

斯卡拉記錄器無法加載

我學習Scala +阿卡，我想在我的小類中添加文件記錄功能，我使用的IntelliJ IDEA 這是我做了什麼：新增依賴性build.sbt內的src/main/resources目錄創建application.conf文件創建logback.xml文件 application.conf文件： akka { loggers = ["akka.event.slf4j.Slf4jLo

0熱度

1回答

油滑3個MySQL RAND（）和更新

我想更新這樣的表完整行： UPDATE tracks SET random_sorting = (CAST(RAND() * 100000 AS UNSIGNED) + 1) 但我不知道該怎麼做，在油滑不通過每一行迭代。有沒有辦法做到這一點？

2熱度

5回答

替代加特林

我最近一直有問題，因爲我的依賴項已更新爲使用netty 4.1，而Gatling尚未更新一段時間，並且仍然只能在Netty 4.0上運行。任何人都知道Gatling的任何替代方法來創建類似的性能測試的模擬和場景，以便在我的Maven生命週期中自動運行嗎？

1熱度

1回答

執行者上的Spark對象（單例）序列化

我不確定我想實現的是否可能。我所知道的是，我正從一個執行器訪問單例對象，以確保它的構造器在每個執行器上只被調用一次。這種模式已經在我的代碼庫中被證明和按照預期用於類似的用例。但是，我想知道的是，如果我可以在驅動程序初始化之後運送對象。在這種情況下，訪問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