scala

2熱度

1回答

當前行爲我用的是舊版本jacoco過此配置： plugins.sbt addSbtPlugin("de.johoop" % "jacoco4sbt" % "2.1.6") build.sbt ... jacoco.settings unmanagedResourceDirectories in Test += baseDirectory.value/"test/resources"

0熱度

1回答

如何延遲附加到另一個akka流的akka流的實現？

的文檔FlowOps#concat指出 ...源一起使用這個流程化，並從生產，直到它的時間來斷言背壓元素只是不停。換句話說，如果我有 sourceA.concat(sourceB) 然後sourceB將在同一時間sourceA物化。我如何推遲sourceB正在實現，直到sourceA完成？我正在使用Akka 2.5.6。

0熱度

1回答

show（）/ count（）永遠不會完成while show（）快速運行

我在本地運行Spark並且出現了一個奇怪的問題。基本上，我可以使用DataFrame的show（）方法輸出任意數量的行，但是，當我嘗試使用count（）或collect（）（甚至是很少量的數據）時，Spark就會停留在該階段。永遠不會完成它的工作。我使用gradle來構建和運行。當我運行 ./gradlew clean run 程序卡住在 > Building 83% > :run 什麼

1熱度

1回答

如何在AKKA-HTTP中驗證完成

我想驗證我的API的完整功能的結果，當它無法將字符串轉換爲Json類型時，Response會生成一個null，我不希望它生成null但說：「沒有發現」，這是我的路線： val route = pathPrefix("auth") { path("signIn") { pathEndOrSingleSlash { post { entity(as[Lo

1熱度

3回答

聚合數組元素明智

非常新的火花/斯卡拉。我想知道是否有一種簡單的方法來以列式方式聚合Array [Double]。這裏有一個例子： c1 c2 c3 ------------------------- 1 1 [1.0, 1.0, 3.4] 1 2 [1.0, 0,0, 4.3] 2 1 [0.0, 0.0, 0.0] 2 3 [1.2, 1.1, 1.1] 然後，一旦聚集，我會看起來像一個表

2熱度

1回答

是否可以檢查源代碼生成中是否修改了文件/文件夾

我正在使用sbt sourceGenerators任務生成代碼。我想跳過處理期間未更改的所有文件/文件夾。如何檢查src/main/scala內部的特定文件/文件夾是否已更改或不存在...

1熱度

1回答

斯卡拉正則表達式被多個空格和新行分割

我經歷了不同的正則表達式文件，但我仍然沒有得到它。我希望有人能夠幫助我。我有一個表是這樣的： program 1 0 1 1 0 0 0 0 0 0 0 1 stmt_list 2 0 2 2 0 0 0 0 0 0 0 3 stmt 4 0 5 6 0 0 0 0 0 0 0 0 我想在一個數組從文件和存儲讀取它。我做了以下內容： val source = io.Source.fr

0熱度

1回答

錯誤的輸出編碼渲染與scalascraper

import net.ruippeixotog.scalascraper.browser.JsoupBrowser import net.ruippeixotog.scalascraper.dsl.DSL._ import net.ruippeixotog.scalascraper.dsl.DSL.Extract._ import net.ruippeixotog.scalascraper.

1熱度

2回答

獲取特定的增量鍵值到一個數組

我有我與指數拉上一個名單： val fun_i_map_e = (list.indices zip list).toMap 現在，我想每個鍵的值遞增，由num:Int： for (k<-0 until list.length by num) for ((k,v) <- fun_i_map_e) { bufferArray += v} 的想法這裏是Java中的這樣的東西：

2熱度

1回答

如何訪問Hive中的現有表？

我想用scala來訪問spark應用程序中的HIVE。我的代碼： val hiveLocation = "hdfs://master:9000/user/hive/warehouse" val conf = new SparkConf().setAppName("SOME APP NAME").setMaster("local[*]").set("spark.sql.warehouse.dir