scala

0ısı

2cevap

Bir örnekte Spark MLlib

'daki bazı bölümlerin yanlış anlaşılması Spark MLLib kullanarak basit bir kişiselleştirilmiş tanıtım önerisi oluşturmak için bunu example takip ediyorum. val numUsers = ratings.map(_._2.user).distinct

scala apache-spark apache-spark-mllib 2016-04-14

---

0ısı

1cevap

Sprey-can/1.3.3 yanıtı nasıl kaldırılır

HTTP isteklerini sunmak için spray.io kullanıyorum. Yanıt olarak, kaldırmak istediğim sprey çerçeve hakkında bilgi var. Peki, spray'daki yanıt başlığından "Server: spray-can/1.3.3" nasıl kaldırılır?

scala spray spray-can 2016-04-14

---

0ısı

1cevap

İşçinin Spark için Hadoop'a da ihtiyacı var mı?

Kurulum scala'm var, Hadoop & kıvılcım & ana düğümü başarıyla başlattı. Ben sadece & kıvılcım kuruluyor & çalışan (köle) de başladı. Öyleyse şaşkın olduğum şey, Haddop'un çalışanlar için de görevlerin

scala hadoop apache-spark cluster-computing 2016-04-14

---

1ısı

1cevap

Scala + Spark + Dataframe Exception Bir sütunu dinamik olarak yayınlamaya ve sıralama sırasını atamaya çalıştığımda

Veri çerçevemi seçili sütunları kullanarak stringtype öğesinden priderred türüne ve prerred order'a dökerek sıralamak istiyorum. Ancak bir sütunun basit bir dökümü bile bu istisnayı ve işe yaramaz. Ör

scala sorting apache-spark casting comparator 2016-04-14

---

1ısı

1cevap

Scala and Spark: CreateStream sırasında hata

Hata: Scala ve Twitter4j kullanarak Spark'de bir tweet akışı oluştururken. Aşağıda benim kod pasajı edilir: scala> val ssc = new StreamingContext(sc, Seconds(10)) scala> val cb = new ConfigurationBui

scala spark-streaming 2016-04-14

---

0ısı

1cevap

Bul max [dize, Set [MyStuff]]

ben aşağıdakileri yapmanız gerekir: grupta çok büyük atma grupları almak bazı dize özelliğiyle kayıtlarım kalan gruplar İşte her birinde en fazla eleman şimdiye kadar ne var: val records: TypedPipe[My

java scala scalding 2016-04-14

---

2ısı

1cevap

Başlangıç ​​HiveThriftServer programlı HiveThriftServer2 gibi belirli bir kovan içeriği için programlama kovan Thrift sunucu başlayan Python'la

kıvılcım kabuk (skalası), ithal olarak , org.apache.spark.sql.hive.thriftserver._ içinde. o belirli oturum için kayıtlı bir geçici tabloyu ortaya çıkarmak için startWithContext (hiveContext). Aynı şey

python scala hive thrift hivecontext 2016-04-14

---

5ısı

1cevap

Niçin Değişken harita kıvılcım

içinde UserDefinedAggregateFunction (UDAF) 'da otomatik olarak değişmez hale gelir Spark içindeki bir UserDefinedAggregateFunction (UDAF) tanımlamaya çalışıyorum; bu, bir grup sütunundaki her bir benz

scala apache-spark mutable user-defined-aggregate 2016-04-14

---

6ısı

2cevap

SBT/Scala ve Entegrasyon testi

Entegrasyon testlerimi otomatikleştirme konusunda araştırma yaparken, FailSafe denilen maven dünyasında güzel bir eklenti buldum. Ön entegrasyon testi, post-entegrasyon testi ve entegrasyon testi gibi

scala sbt 2016-04-14

---

1ısı

2cevap

2.4 parametreli cebirsel veri türleri JSON doğrulama

o 2.4 Çal/Scala böyle bir şey yapmak mümkün mü oynayın: sealed trait Location { val `type`: String } case class CityLocation(zip_code: String, override val `type`: String = "city") extends Location

json scala playframework-2.4 2016-04-14

---