scala

1熱度

1回答

我曾經是能夠通過命令行傳遞標籤黃瓜紅寶石運行特定的場景即cucubmer --tag wip 有沒有辦法在做它的命令行斯卡拉。我試圖做到這一點，但它似乎並沒有工作。 -Dcucubmer.options="--tags @wip"

0熱度

1回答

我試圖寫一個自動重試事務「猴子補丁」的浮油（1.0，不幸）。另外，我希望它只能在特定類型的例外情況下重試。不幸的是，我一直在運行類型擦除的問題。從我所瞭解的情況來看，我試圖做的就是結束混合運行時和編譯時的習慣用法，但在這一點上，我完全沒有想法。我是否嘗試使用反射？ object SessionSupport { /** * Patches the session object

0熱度

1回答

寫HDFS OUTPUTFILE使用Scala

我想寫使用Scala的一個HDFS輸出文件，我收到下面的錯誤：例外在線程「主要」 org.apache.spark.SparkException：任務不可串行化的 at org.apache.spark.util.ClosureCleaner $ .ensureSerializable（ClosureCleaner.scala：315） at org.apache.spark.util.Clos

0熱度

1回答

如何變換油滑2.1.0 MappedProjection所以它的所有列選項

比方說，我有一個名爲Blarg由屬性與基本類型的情況下類： case class Blarg( x: String, y: Int ) Blarg S IN各種類使用，有時如Option[Blarg]，有時爲List[Blarg]，並且這些類是持久的。我們也有一個名爲OptionalComplexThing含Option[Blarg]類型的屬性的情況下類： case cla

2熱度

1回答

Akka Stream：在圖形構建器階段動態增長插座

我在Akka Stream中瞭解到，一個插座必須連接到一個插座，並且沒有自動支持將多個接收器連接到相同的信號源。所以你必須插入中間對象，如Broadcast。我正在將一個信號處理DAG轉換爲一個Akka Stream圖，如果我可以在通過遍歷發現它們時動態地添加接收器，它將會對我有很大的幫助。如果我有自定義GraphStage，我可以在Graph.create階段有我自己的Shape的outlet

0熱度

1回答

預測IO：爲引擎配置超時

我有一個訓練有素的模型，可以毫不費力地部署。然而，查詢API將收到的響應：服務器無法產生對你的要求一個簡單的谷歌搜索（和過去的經驗）的及時反應告訴我，這是噴霧告訴我答覆時間太長。我想能夠增加超時但我找不到如何配置引擎。任何想法如何我可以改變引擎使用的配置？

0熱度

1回答

scala/slick中的哪個數據類型與mysql中的geopoint匹配？

這個問題很簡單。基本上我有一個表格，它有一個POINT類型的列。在slick中創建類型映射時，應該使用哪個類映射該列類型？

2熱度

1回答

什麼是在Scala中執行數百萬個獨特轉換的功能方法？

我有一個對象Person，這個對象經歷了數百萬個獨特的轉換，並且這些轉換必須按順序完成。傳統上，我可以這樣做： var bob = new Person() birth(bob) oneYearOld(bob) middleSchool(bob) highSchool(bob) // ...million more transformations 所以我的問題是，我怎麼能在Scal

0熱度

3回答

是否有可能通過子句中指定動態

的（我< -1〜100 [在這裏，我想這在程序運行期間改變條款]）所以，說，我有一個變量這是目前輪到的期望差距。我用while循環重寫了它，但是有沒有機會用構造來完成它。 var gap = 1 for(i<-1 to 100 by gap) gap+=1

1熱度

2回答

如何過濾基於關鍵字列表的Scala SQL上下文數據框中的文本

我一直試圖根據選定的主題標籤過濾來自SQL數據框的推文。我的代碼（下面給出）適用於我嘗試過濾所選哈希標籤的推文。 dfs.select(dfs("text")) .map(r => r.getString(0)) .filter(_.contains("#tweet_of_interest")) .foreach(println) 然而，當我向我的代碼過濾基於存儲