scala

1熱度

1回答

Spark中的K-means（Scala） - 當從標準化數據建立模型時如何將簇號映射回客戶ID

以下代碼用於獲取模型。我面臨的問題是將羣集號映射回客戶ID。這是因爲，我的模型接受了標準化數據的培訓，但帶有客戶ID的數據的數據沒有標準化。我無法弄清楚如何映射回去。 import org.apache.spark.SparkContext._ import org.apache.spark.mllib.clustering.{KMeans, KMeansModel} import org.a

1熱度

2回答

如何在Intellij中使用現有的Scala

我已經有brew install scala - 我可以通過命令行運行Scala。從那以後，我的IntelliJ安裝版本2016年1月3日雖然的IntelliJ的安裝過程中，我被要求安裝斯卡拉插件，但我點擊沒有 - 因爲我已經有斯卡拉安裝現在我試圖準確找出其中我們可以使用我現有的Scala來安裝Scala應用程序。我可以在IntelliJ中如何和在哪裏設置它？我只能看到可以創建的Java項目。

0熱度

1回答

Spark DataFrame AnalysisException

我想從數據框（scala語言）中選擇幾列。問題是，我無法將所有列放入單個字符串並傳遞給DataFrame的選擇函數。我嘗試以下，但它不工作： scala> val str1 = "sum(\"bal1\")/100," str1: String = sum("bal1")/100, scala> val str2 = "sum(\"bal12\")/100," str1: String

6熱度

2回答

獲取超過20行並在火花外殼中顯示列的全部值

我使用spark-shell中的cassandraSQL查詢來自cassandra的數據。所以，我想知道如何使用cassnadraSQL獲取超過20行的兩件事，第二我如何顯示列的完整值。正如您在下面默認看到的，它會在字符串值中追加點。代碼： val csc = new CassandraSQLContext(sc) csc.setKeyspace("KeySpace") val maxDF

7熱度

1回答

在scalaz免費實施

在Haskell自由的實現是： data Free f a = Pure a | Free (f (Free f a)) ，而在Scalaz實現如下： sealed abstract class Free[S[_], A] private case class Return[S[_], A](a: A) extends Free[S, A] private case class Su

2熱度

1回答

星火動態分配在獨立集羣失敗在我的應用

我正在星火1.5.2建立在斯卡拉2.11在Windows 7羣集上獨立模式和兩個與分配給這兩個應用所有核心星火應用。當我運行應用程序完成的我的應用程序沒有的兩個實例啓用動態分配功能從配置。這裏是我的應用程序 - package com.cleartrail.clearinsight.spark; import java.util.Arrays; import java.util.Lis

1熱度

1回答

實例化一個單一的連接於油滑3.0

與性狀混入到DB I具有的性狀，其限定一個分貝連接： trait Db { val db: Database = Database.forConfig("twitter-indexing-db") } 然後我延伸在另一特徵，其中我利用Db像這樣： trait TwitterIndexingRepository { self: Db => ... } 最後，

7熱度

1回答

如何避免使用logback進行雙重記錄？

在我的應用程序中，我想以特定方式記錄來自我自己代碼的一些消息，與所有其他正在記錄的消息進行比較。但我不知道如何避免它們也被自動記錄到logack根記錄器。使用下面的配置，我想使用如下代碼（scala），這樣我就可以將某些消息記錄到該記錄器。 val logger: Logger = LoggerFactory.getLogger("data-logger") 但是，在下面的配置中，這些消息被

0熱度

1回答

Flink java.lang.ClassNotFoundException：play.api.libs.json.Reads

我正在寫一個代碼，它從文本文件中讀取並將每一行解析爲Json，但Flink中的作業（1.0.3 - Cluster 2個Taskmanagers）失敗與日EXCETION：java.lang.ClassNotFoundException: play.api.libs.json.Reads 我的代碼： import org.apache.flink.streaming.api.scala._ im

2熱度

1回答

貓嵌套異或catchOnly leftMap

我有了它可以拋出可具有商業意義或可返回不同的結果類型（通過動態類實例化）自定義異常的方法底層的Java API。其中，該方法返回一個結果我有一個A Xor B其中A是錯誤的類型，但我想用Xor.catchOnly[CustomException]與leftMap方法將異常轉換成A. import cats.data.Xor import scala.reflect.ClassTag def