scala

1熱度

1回答

我有以下兩種情況下的類，請注意，第二種包括第一種（用戶案例類）。 case class User(sk: Int, userid: String, firstName: String, lastName: String, email: String, notes: String) case class UserAp

0熱度

2回答

Scala - fromPublisher不是對象的成員akka.stream.scaladsl.Source

我剛開始使用Scala（2.11.7）中的akka流（2.4.6）和slick（3.1.1）。我使用Intellij（不確定是否重要，但我認爲我會把它扔掉）。 val scanner: DatabasePublisher[Stage] = db.stream(action.transactionally.withStatementParameters(fetchSize = 5000)) v

1熱度

1回答

log4j中的參數化替換需要空字符串？

./spark-shell scala> import org.slf4j.{Logger, LoggerFactory} import org.slf4j.{Logger, LoggerFactory} scala> val LOGGER = LoggerFactory.getLogger("testing") LOGGER: org.slf4j.Logger = org.slf4j

0熱度

1回答

添加從地圖值到JSON各個領域斯卡拉

我有一個文件列表，用它可以添加到一個JSON對象分別字段和值在Map[String, Any]的形式，以便數據。所以，我的代碼解析的時候看起來是這樣的： val JsonDoc = Json.obj( "ORFID" -> doc("ORFID").toString, "ORF_len" -> doc("ORF_len").toString, "start" ->

0熱度

1回答

定義地圖[詮釋，字符串]長字符串作爲權值

我試圖使用字符串litterals的串聯如在Map[Int, String]定義值： scala> val m: Map[Int, String] = Map(1 -> "a" + "b") ，但我得到以下錯誤sbt console <console>:7: error: type mismatch; found : String required: (Int, String)

1熱度

2回答

錯誤從星火

我試圖用飛艇筆記本取data from DynamoDB with Apache Spark 計數運行良好，但除此之外，我不能像 orders.take(1).foreach(println) 運行任何構建一個快速報告閱覽DynamoDB記錄出現以下錯誤： org.apache.spark.SparkException: Job aborted due to stage failure: Ta

2熱度

5回答

在Scala中具有兩個值的匹配列表

我想編寫一個匹配具有Scala中兩個值的列表的算法。舉例來說，如果我有以下列表： val list = List(1, 3, 6, 8, 9, 14, 18) 而且有這樣的兩個值： val a = 4 val b = 14 我想這個名單： val result = List(6, 8, 9, 14) 如果是考慮使用Scala的intersect方法，但只適用於兩個列表。我也想過

0熱度

1回答

將JSON數據解析爲Scala列表和HashMap

我有如下所示的JSON數據。我正在使用Python將列表，字典和另一個列表編碼爲JSON。最終的JSON數據看起來就像這樣： { "0": [3, 3, 3], "1": { "0": [0, 8, 9], "1": [1, 2, 3, 4, 10, 11], "2": [4] }, "2": [1, 1, 1, 1] } 我的目標是寫一些類型的Scala功能的方式，允許提取JSON數據： "0"

0熱度

1回答

Scala -jline文件完成程序導致找不到文件（linux）

我在這段代碼中看到了一些非常奇怪的東西。 command match { case "q" | "quit" => done=true case "f" | "file" => { // console_reader.addCompleter(fn_completer) val f:String=console_reader.readLine(

0熱度

1回答

在Spark中初始化羣集中心

我試圖做一些與此問題非常相似的事情： How to initialize cluster centers for K-means in Spark MLlib? 但是，我並不完全瞭解該解決方案。當我嘗試加入更多的重心，我得到一個錯誤： Exception in thread "main" java.lang.IllegalArgumentException: requirement failed: