scala

    -1熱度

    1回答

    使用UDF意味着每個因子c1,c2,c3必須獨立傳遞參數。有沒有靈活的解決方案,例如如何將這些因子的序列傳遞給UDF? val myFunction = udf { (userBias: Float, productBias: Float, productBiases: Map[Long, Float], userFactors: Seq[Float], productFa

    0熱度

    1回答

    我試圖查詢部署PredictionIO發動機類似如下: curl --max-time 2000 --connect-timeout 60 -H "Content-Type: application/json" \ -d '{ "ids": [ "AAAAAAAA-9999-4444-ACAC-18181818181818" ], "oth

    5熱度

    1回答

    我想創建通過過濾器一個新的數據幀出這是使用下面的代碼null或空字符串行: val df1 = df.filter(df("fieldA") != "").cache() 然後我得到了以下錯誤: <console>:32: error: overloaded method value filter with alternatives: (conditionExpr: String)

    2熱度

    2回答

    刪除零行我的目錄列表中斯卡拉如: val lst = List(List(60, 0, 1, 2, 3, 28, 0, 0, 0, 0), List(0, 0, 0, 0, 0, 0, 0, 0, 0, 0), List(47, 0, 1, 1, 2, 28, 0, 0, 0, 0)) ,我要刪除所有零行,結果應該是這樣的: List(List(60, 0, 1, 2, 3, 28, 0, 0

    0熱度

    1回答

    個別服務器運行良好,請任何想法在這[我創建了兩個服務器,但當我嘗試運行simentaneously它顯示此錯誤] [1]。 我已經在使用運行的第一臺服務器作爲 :遊戲運行9000 第二個服務器作爲遊戲運行9001 這是正確的? [錯誤即將這樣的(終端複製/粘貼)] 在org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(Abstrac

    0熱度

    1回答

    我們使用SciSpark使用SRdd的概念讀取NetCDF文件。一旦我們疲勞讀取1GB以上的文件,我們就會收到錯誤信息。 VAL數據= sc.OpenPath( 「/家庭/項目/ TESTDATA」,列表( 「朗姆酒」)) 有沒有在此代碼的任何問題嗎? 收到錯誤:java.lang.OutOfMemoryError:Java堆空間

    4熱度

    2回答

    我試圖解決akka流的問題,我希望我的初始生產者可以連續獲取隊列/ mongodb集合,並在配置的時間間隔內完成它。常見的做法來實現呢?

    1熱度

    2回答

    我想從我的代碼(scala項目)連接到TitanDB。代碼和gremlinserver/titandb位於兩個不同的主機中。 在此example中,連接是由安裝了titandb的同一主機進行的。 如果我不在同一主機上運行代碼會怎麼樣? 我想可能有一個配置文件,我把主機名和端口。但我找不到像這樣的東西。 所以問題是:從代碼遠程連接到泰坦服務器可能嗎? 預先感謝您

    2熱度

    1回答

    比方說,我定義的特質某種類型的,應該實施一些類型的類(如仿函數): import cats.Functor import cats.syntax.functor.toFunctorOps trait Library { type T[+A] implicit val isFunctor: Functor[T] } 現在,我想使用這個庫。以下工作正常: trait L

    1熱度

    1回答

    最初我想在我的模型中映射MongoDB的_id。例如: case class User(_id: Option[BSONObjectID], ...) 然而,這引起了很多的問題,因爲我必須設置_id後,我插入用戶的文檔。因此,我用Java的UUID類取代了這個屬性。這意味着我的模型中只有id,數據庫中只有_id以及id。我現在開始爲我的所有模型使用它,因爲我認爲在模型中存儲與數據庫相關的信息是