scala

2熱度

1回答

我需要測試Akka中的兩名子女的父母。在我的整合測試中，我需要嘲笑這兩個孩子中的一個。兩個孩子都是在構造函數中創建的。我怎麼弄到的？ MyParentActor { val childOne = ChildOne.props(...) val childTwo = ChildTwo.props(...) ... }

0熱度

1回答

JsValue系列化失敗

在我的應用我使用https://github.com/fommil/spray-json-shapeless庫serializaion，但我有問題，這個類： case class FooResult(var id: Option[String], jobId: String, completedAt: DateTime, result: JsValue) extends JobResult i

0熱度

1回答

爲什麼這個值沒有被返回，因爲它應該在這裏？

這爲什麼有效？ object Foo extends App { def bar(s: String): String = { if (s.size == 0) "empty string" else if (s.size == 1) s + s else s.head + bar(s.tail) } println(bar(""))

0熱度

1回答

在沒有Spark的Scala中使用Parquet-mr

我想在不使用Spark的情況下在Scala中讀取.parquet文件。我找到了this SO post，但到目前爲止一直無法找到如何使用parquet-mr library實際從文件中讀取數據（包括獲取模式）。有像RecordReader.java和RecordReaderImplementation.java（它擴展了RecordReader）的東西，但我很努力去理解如何在我的Scala代碼中

0熱度

1回答

如何在Spark-scala中實現LEAD和LAG

我在spark數據框中有最終記錄（在連接和過濾之後）。我需要比較連續行的（按鍵分區）列值並基於條件需要更改e_date列值例如： sample table key1 key 2 col1 col2 s_date e_date a 1 cv1 cv2 2014 2099 a 1 cv3 cv2 2016 2099 b 2 cv5 c

0熱度

2回答

使用spark sql將json數據加載到配置單元中

我無法將json數據推入配置單元下面是示例json數據和我的工作。請建議我缺少一個 JSON數據 { "Employees" : [ { "userId":"rirani", "jobTitleName":"Developer", "firstName":"Romin", "lastName":"Irani", "preferredFullName":"Romin Irani",

3熱度

1回答

爲什麼地圖變換很窄？

我知道RDD的窄變換和寬變換之間的區別。我的問題是認證地圖的參數是什麼，平面地圖很窄？爲什麼這些轉變不是很廣泛？有關RDD學習材料的任何建議，我們感謝。

0熱度

1回答

路徑依賴類型示例不起作用

Scala n00b here。很確定我理解PDT，但是確定並且遇到問題;這裏有一個先前的問題Scala types: Class A is not equal to the T where T is: type T = A與示例代碼我將在這裏重現： 1: class Food 2: class Fish extends Food 3: class Grass extends Food 4:

0熱度

1回答

在自定義枚舉中使用反射來獲取可能的值

我正在處理一些使用自定義枚舉的代碼來確保完整性檢查，並且它需要使用反射來獲取可能值的列表。類似下面的代碼已經在代碼庫中（所有不相關的東西都被刪除和/或重命名）我已經將它們放在一起成爲獨立的可運行格式。 import scala.reflect.runtime.universe.TypeTag object ReflectionUtil { def modules[A : TypeT

5熱度

2回答

如何在運行時編譯/評估Scala表達式？

斯卡拉新手，尋找指向一個慣用解決方案的指針，如果有的話。我想要任意用戶提供的Scala函數（可以引用我在代碼中定義的函數/類）應用於某些數據。例如：我有我的myprog.scala中定義的foo(s: String): String和bar(s: String): String函數。用戶運行我的程序是這樣的： $ scala myprog data.txt --func='(s: Str) =