Suchergebnisse für Anfrage "scala"
Wie verwende ich Flinks KafkaSource in Scala?
Ich versuche, ein einfaches Testprogramm mit Flinks KafkaSource auszuführen. Ich benutze folgendes: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Ich habe die Dokumentation befolgt, um KafkaSource zu testen (hinzugefügte Abhängigkeit, Bündelung des ...
String-Interpolation, ohne Anführungszeichen
Ich bin etwas verblüfft, wie schwierig das wird. Ich habe mich bereits in stackoverflow umgesehen, aber keine Lösung scheint für mich in Ordnung zu sein. Was ich machen will; was ich vorhabe zu tun val file = checkcache(fileName) file match { ...
SparkContext in einem Begleitobjekt nicht serialisierbar
Ich versuche derzeit, eine Anwendung für maschinelles Lernen zu erweitern, die Scala und Spark verwendet. Ich verwende die Struktur eines früheren Projekts von Dieterich Lawson, das ich auf Github @ gefunden hab https: ...
Wie registriere ich eine Funktion in sqlContext UDF in scala?
Ich habe eine Methode namens getAge (Zeitstempel: Long) und möchte diese als SQL-Funktion registrieren. Ich hab sqlContext.udf.register("getAge",getAge)Aber es sagt mir, ich brauche Argumente oder benutze danach _, ich habe versucht, _ zu ...
Wie konfiguriere ich das Ivy-Cache-Verzeichnis pro Benutzer oder systemweit?
Ich benutze SBT [http://www.scala-sbt.org/] als mein Build-Tool zum Erstellen eines Scala-Projekts. Mein Problem ist, dass ich SBT nicht so konfigurieren kann, dass Abhängigkeiten in mein Benutzer-Ausgangsverzeichnis heruntergeladen werden. Aus ...
Wie vereinfache ich verschachtelte Kartenaufrufe?
Angenommen, ich habe ein paar verschachtelte Funktoren, z.List[Option[Int]] und müssen das @ aufrufmap der innersten. Jetzt verwende ich verschachteltemaps: scala> val opts: List[Option[Int]] = List(Some(0), Some(1)) opts: List[Option[Int]] = ...
Abstrakte Typen versus Typparameter
n welchen Situationen sollten abstrakte Typen den Typparametern vorgezogen werde
Wiederholen Sie ein Zeichen / eine Zeichenfolge n-mal in Scala
Ich möchte Folgendes effizienter ausführen: def repeatChar(char:Char, n: Int) = List.fill(n)(char).mkString def repeatString(char:String, n: Int) = List.fill(n)(char).mkString repeatChar('a',3) // res0: String = aaa repeatString("abc",3) // ...
Mischen Sie zwei RDDs in Spark Scala
Ich habe zwei RDDs. rdd1 = (String, String) key1, value11 key2, value12 key3, value13 rdd2 = (String, String) key2, value22 key3, value23 key4, value24Ich muss eine andere RDD mit zusammengeführten Zeilen aus rdd1 und rdd2 bilden, die Ausgabe ...
RDD zu LabeledPoint Konvertierung
Wenn ich eine RDD mit etwa 500 Spalten und 200 Millionen Zeilen habe undRDD.columns.indexOf("target", 0) zeigt anInt = 77 gibt an, dass sich meine abhängige Zielvariable unter der Spaltennummer 77 befindet. Ich habe jedoch nicht genügend ...