scala

    0熱度

    2回答

    我需要使用幻像和卡桑德拉實現通知模型的幫助。我已經做了到現在什麼: import java.util.UUID import com.websudos.phantom.dsl._ import com.websudos.phantom.connectors.Connector import org.joda.time.DateTime import scala.concurrent.F

    1熱度

    1回答

    我目前所面臨的一個問題,而試圖挽救一個Apache星火DataFrame從阿帕奇星火臨時table加載到分佈式MemSQL database MemSQL數據庫。 訣竅是目前我不能使用MemSQLContext連接器。所以我使用JDBC driver。 這裏是我的代碼: //store suppliers data from temp table into a dataframe val sup

    1熱度

    1回答

    我正在尋找一個示例play framework項目,演示如何通過scala play框架應用程序中的freeslick訪問oracle數據庫。 任何提示?

    2熱度

    1回答

    我試圖在Windows 10安裝星火1.6.1,到目前爲止,我已經做了以下... 下載火花1.6.1,解壓到某個目錄,然後設置SPARK_HOME 下載2.11.8階,解壓到某個目錄,然後設置SCALA_HOME 設置_JAVA_OPTION環境變量 由剛下載的zip目錄,然後設置HADOOP_HOME環境變量從https://github.com/steveloughran/winutils.g

    3熱度

    2回答

    我不確定我在這裏正確使用@volatile。我有一個緩衝區,像這樣: final class BufD(val buf: Array[Double], @volatile var size: Int) 哪些在進程之間發送,從而它可能跨越線程邊界。在發送之前,發件人可能會更新size字段。因此,我想確保接收器在任何情況下都不會在此處看到陳舊的size值。 第一個問題:@volatile確保這個或

    1熱度

    2回答

    通常您會在事務中運行兩個或多個語句。但在所有可以在Slick 3中使用transactionally找到的例子中,我通常在循環中使用for來理解將這些語句分組。 這個工作(從兩個表中刪除一個事務): val action = db.run((for { _ <- table1.filter(_.id1 === id).delete _ <- table2.filter(_.

    2熱度

    2回答

    我想在沒有var定義的情況下實現定期更新的值。 比方說,如果我有Web服務器,必須做其他服務器的健康檢查,以處理用戶請求。每個用戶請求操作都會引用健康檢查結果。 如果每次處理新請求時進行健康狀況檢查,則會花費巨大的費用,而是每5分鐘最多更新一次健康狀況檢查結果值。 這很簡單如果我使用var來實現這一點。 private var result = false private var las

    3熱度

    2回答

    我是scala的新手,並嘗試一些簡單的練習。 我試圖通過將implicits放在同伴對象中來使用implicits。但是,除非使用它,否則編譯器不會檢測隱式。 class ImplicitTest { import Implicits.implicitInt; println(implicitInt) def implicitm1(implicit i : Int)

    6熱度

    6回答

    我有以下類: case class Profile(email: Option[String], firstName: Option[String], lastName: Option[String], fullName: Option[String]) 現在我想刪除fullName屬性,因爲它是多餘的。但是,我有一個方法,在我的課User

    0熱度

    1回答

    我想在斯卡拉desrialize二進制消息反序列化二進制節儉消息: val deserializer = new TDeserializer(new TBinaryProtocol.Factory()); try { val obj = deserializer.deserialize(new ClientError{}, input._2.toArray) 哪裏Clie