scala

4熱度

1回答

對象kafka不是包org.apache的成員

將java驅動程序導入到我的scala項目中時，Im在編譯時碰到以下消息：object kafka is not a member of package org.apache。這裏是我的import語句是如何設置的： import org.apache.kafka.clients.producer.{Callback, KafkaProducer, ProducerRecord, RecordMe

java scala apache-kafka 2016-05-27

---

-1熱度

1回答

來自Scala Spark和pyspark工作的輸出不一致

我正在將我的Scala代碼轉換爲像下面這樣的pyspark，但得到了最終RDD的不同計數。 我的Scala代碼： val scalaRDD = rowRDD.map { row: Row => var rowList: ListBuffer[Row] = ListBuffer() rowList.add(row) (row.getString(1) + "_

scala apache-spark pyspark rdd 2016-05-27

---

4熱度

1回答

Spark中的「錯誤：類型不匹配」，找到和需要的數據類型相同

我正在使用spark-shell來運行我的代碼。在我的代碼中，我定義了一個函數，並使用它的參數調用該函數。 問題是我調用該函數時出現以下錯誤。 error: type mismatch; found : org.apache.spark.graphx.Graph[VertexProperty(in class $iwC)(in class $iwC)(in class $iwC)(in cla

scala apache-spark spark-graphx 2016-05-27

---

1熱度

1回答

如何應對這種日誌包含JSON

這裏是日誌： "V2|ip-10-203-5-16|PSDK_KINESIS_LOG|PSDK_DEFAULT|2016-05-12 00:00:05|VP|aa2ddfdb-4387-49c0-9651-92cc83b8e905|{"vid":"2237031","fdn":"FDNB1995115","type":"0","version":"1.0","device_id":"SCL-TL0

json scala apache-spark apache-spark-sql 2016-05-27

---

1熱度

1回答

Deadbolt2 - > SecureSocial /剪影集成

任何人設法Deadbolt2與剪影/ SecureSocial集成？ 我覺得剪影授權位基本和Deadbolt2符合所有要求。 感謝

scala playframework securesocial silhouette deadbolt-2 2016-05-27

---

0熱度

1回答

Kafka producer.send（）被producer.close（）停止

我試圖在一個名爲「test」的kafka主題上發送一個字數問題（在spark-scala中）的輸出。看到下面的代碼： val Dstream = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc, kafkaParams, topicsSet) val lines = Dstream.

scala apache-kafka kafka-producer-api 2016-05-27

---

4熱度

1回答

'錯誤的頂部聲明聲明'當在IntelliJ中使用光滑

我目前正在將一個項目從scala 2.9移植到2.10，因此我必須使用slick而不是scalaquery。我現在使用slick 2.1.0，因爲它支持MS Access。 根據this tutorial和upgrade guide我改變Robs從對象類，並增加了VAL robs： 爲什麼我收到錯誤信息Wrong top statement declaration，我如何擺脫它？ 編輯：我是新來的

scala intellij-idea intellij-scala 2016-05-27

---

1熱度

1回答

使用Sql Server配置Slick

我有一個項目正在使用MySQL，我想遷移到SQL Server（在Azure上運行）。我已經嘗試了很多配置的組合，但總是得到相同的一般錯誤消息： Cannot connect to database [default] 這裏是我的最新配置的嘗試： slick.dbs.default.driver = "com.typesafe.slick.driver.ms.SQLServerDriver"

sql-server scala playframework azure-sql-database 2016-05-27

---

5熱度

1回答

斯卡拉與VAL覆蓋高清，拋出NPE

我學習Scala和Programming in Scala 3rd Ed，Ch 10, Page 225，部分Overriding methods and fields，它說 的統一訪問原則僅僅是一個方面的基礎斯卡拉對待 字段和方法更均勻地比Java 。另一個區別是在Scala中， ，字段和方法屬於同一個命名空間。這個 使字段可以覆蓋無參數的方法。對於 例如，你可以 ArrayElement從一個

scala 2016-05-27

---

2熱度

1回答

等價於Pandas Dataframe`.iloc（）`方法的Spark DataFrame？

有沒有辦法引用Spark DataFrame列按位置使用整數？ 類似熊貓據幀操作： df.iloc[:0] # Give me all the rows at column position 0

scala pandas apache-spark spark-dataframe 2016-05-27

---