scala

8熱度

2回答

當我運行下面的代碼， class A(private[this] var i: Int) { println("i = " + i) i -= 1 println("After decrement, i = " + i) override def toString = i.toString } object A extends App { v

0熱度

1回答

斯卡拉地圖收集案例映射類（）

我有2例類： case class OutlierPortal(portal: String, timeData: Seq[OutlierPortalTimeSeriesData]) 和 case class OutlierPortalTimeSeriesData(period: Timestamp, totalAmount: Double, isOutlier: Int) 或分別爲Seq

1熱度

1回答

如何使用scala中的fileStream（）在Spark Streaming中找出文件名稱？

我到處尋找如何找到Spark Streaming在fileStream（）方法中拾取的每個文件的名稱。在Java中有一些局部解決方案，但我找不到Scala示例。也有不完整的建議使用FileInputFormat，這是不清楚如何使用。任何Scala示例代碼將不勝感激。

2熱度

2回答

播放WS API：限制請求速率

我正在使用異步播放WS Scala API來查詢REST式服務。我想知道如何處理List，其中包含通過WSClient調用的請求URL，但每秒請求數不超過一個（該服務允許「每個客戶端每秒只有」1個請求）。從邏輯的角度來看，這個想法是從列表中獲取一個元素（URL），發出請求，然後等待一定的時間，然後再繼續處理列表中的下一個元素。在像Play這樣的非阻塞和異步框架中使用舊的Thread.sleep肯

2熱度

1回答

功能「找到對的，加起來X」與線性時間複雜度

我試圖實施「找到對的，加起來X」具有線性時間複雜功能，爲此，我有以下幾點： def pairs(nums: List[Int], sum: Int): List[(Int, Int)] = { def pairsR(nums: List[Int], sum: Int, start: Int, end: Int, acc: List[(Int, Int)]): List[(Int, In

1熱度

2回答

包含列表

燙flatMap元組我有，我想下面的輸入元組flatMap：(String, List[String]) E.G.輸入： ("a", ["1", "2"]) ("b", ["3", "4"]) 所需輸出： ("a", "1") ("a", "2") ("b", "3") ("b", "4") 有一種優雅的方式在滾燙/斯卡拉做到這一點？

3熱度

2回答

使用Scala處理TitanDB中的異步事務時遇到問題未來

我正在使用Titan事務API來處理我的代碼中的事務。它的做工精細，這裏是我的代碼：同步交易： def syncTransaction()={ val transaction = titanGraph.newTransaction // doing some modification and query , creation vertex transacti

0熱度

1回答

如何爲此json輸入構建一個case類並將其轉換爲對象？

我從一個Web API這個JSON字符串： {"results":{"Inne":"23.3","Ute":"5.8"}} 如何構造的情況下，類此輸出相匹配？這是我的嘗試： case class Results(Inne: String, Ute: String) object MyJsonProtocol extends DefaultJsonProtocol { impli

0熱度

1回答

Scala的Vert.x 3文檔

Here是關於在Scala中使用Vert.x 2的文檔。是否有關於在vert.x 3中使用Scala的文檔？它在哪裏？

3熱度

1回答

將Spark DataFrame從Python移動到Scala中Zeppelin

我在Zeppelin的Python段落中創建了一個Spark DataFrame。 sqlCtx = SQLContext(sc) spDf = sqlCtx.createDataFrame(df) 和df是大熊貓數據框 print(type(df)) <class 'pandas.core.frame.DataFrame'> 我想要做的是從一個Python的段落到另一個段落斯卡拉移動