scala

    0熱度

    2回答

    我有一些用Thrift(Scrooge)生成的Scala類。現在,我需要以某種方式實例爲那些TBASE類,B/C的TSerializer類需要以此爲輸入 這是我的方法: def createTestBinary(): String = { val proto = new TBinaryProtocol.Factory val err = new ClientError{}

    1熱度

    1回答

    我試圖將Spark中的數據框轉換爲配置單元表。我從一個XML文件讀取了一個數據框。它使用SQL上下文來執行此操作。我想將此數據框保存爲配置表。我收到此錯誤: "WARN HiveContext$$anon$1: Could not persist database_1 . test_table in a Hive compatible way. Persisting it into Hive me

    0熱度

    1回答

    我的Scala代碼塊的樣子, val orgIncInactive = orgIncLatest.filter("(LD_TMST != '' and LD_TMST is not null)").select("ORG_ID").rdd orgIncInactive.collect.foreach(p => DenormalizedTablesMethodsUtil.hbaseTablePu

    0熱度

    1回答

    我有akka camel-ftp消費者。我想處理代碼中的所有異常(例如,身份驗證異常,或無法讀取ftp上的文件)。我只能看到日誌中的堆棧跟蹤,無法處理它。 也許最好使用scalaz-camel。 此外,我想知道,當所有的文件處理和演員閒置,直到下一次讀的FTP文件夾 class FtpWorkerActor() extends Consumer with ActorLogging {

    5熱度

    1回答

    我期待到阿卡HTTP "com.typesafe.akka" %% "akka-actor" % "2.4.6", "com.typesafe.akka" % "akka-http-experimental_2.11" % "2.4.6" 我測試了簡單的代碼,如下圖所示。 我的主要問題是如何增強它以獲取關閉連接通知,所以我可以打印當前打開的連接數量? object StatsRepo

    -5熱度

    2回答

    我在Scala中使用java.text.SimpleDateFormat將字符串轉換爲日期。 val isdf = new SimpleDateFormat("dd/MM/yyyy") isdf.parse("01/22/2016") gives Sun Oct 01 00:00:00 UTC 2017 如何解決這個問題?有其他選擇嗎?

    2熱度

    1回答

    我想從Scala名稱中獲取底層Java名稱。 例如: scala> trait `Foo~` defined trait Foo$tilde scala> magicTranslatorMethod("Foo~") res0: String = Foo$tilde 是此功能在Scala編譯器/反射曝光/地方公共API地方?

    2熱度

    1回答

    我有以下代碼試圖合併兩行: import org.apache.spark.sql._ def mergeRow(row1:Row, row2:Row):(Boolean, Row)= { var z:Array[String] = new Array[String](row1.length) var hasDiff = false :

    2熱度

    1回答

    這是我用來刪除「。」的命令。從在火花一階DF列數據,是工作的罰款 rfm = rfm.select(regexp_replace(col("tagname"),"\\.","_") as "tagname",col("value"),col("sensor_timestamp")).persist() 但這不是努力消除在同一列數據 rfm = rfm.select(regexp_replace

    0熱度

    1回答

    讀http://reactivemongo.org/releases/0.11/documentation/tutorial/consume-streams.html添加有此代碼 import scala.concurrent.Future import scala.concurrent.ExecutionContext.Implicits.global import play.api.li