Ich bevorzuge Python gegenüber Scala. Da Spark nativ in Scala geschrieben ist, hatte ich aus offensichtlichen Gründen erwartet, dass mein Code in der Scala schneller ausgeführt wird als in der Python-Version. Mit dieser Annahme dachte ich, ich würde die Scala-Version eines sehr gängigen...
val map1 = Map(1 -> 9 , 2 -> 20) val map2 = Map(1 -> 100, 3 -> 300) Ich möchte sie zusammenführen und die Werte derselben Schlüssel summieren. Das Ergebnis wird also sein: Map(2->20, 1->109, 3->300) Jetzt habe ich 2 Lösungen: val list = map1.toList ++ map2.toList val merged =...
Wenn ein ausfallsicheres verteiltes Dataset (RDD) aus einer Textdatei oder -sammlung (oder aus einem anderen RDD) erstellt wird, müssen wir "Cache" oder "Persist" explizit aufrufen, um die RDD-Daten im Speicher zu speichern? Oder werden die RDD-Daten standardmäßig verteilt im Speicher gespeichert?...
Ich habe eine Funktion namens implicitlyScala gesehen, die in Scala-Beispielen verwendet wird. Was ist das und wie wird es verwendet? Beispiel hier : scala> sealed trait Foo[T] { def apply(list : List[T]) : Unit }; object Foo { | implicit def stringImpl = new Foo[String] { | def apply(list :...
Was ist ein guter Weg, um sich in einer Scala-Anwendung anzumelden? Etwas, das mit der Sprachphilosophie übereinstimmt, den Code nicht überladen und wartungsarm und unauffällig ist. Hier ist eine grundlegende Anforderungsliste: einfach macht den Code nicht unübersichtlich. Scala ist großartig für...
Eine praktische Funktion von Scala ist lazy val, dass die Auswertung von a valverzögert wird, bis es notwendig ist (beim ersten Zugriff). Natürlich lazy valmuss ein gewisser Overhead auftreten - irgendwo muss Scala nachverfolgen, ob der Wert bereits ausgewertet wurde, und die Auswertung muss...
Wenn ich eine Sammlung cvon Typen habe Tund eine Eigenschaft pfür T(z P. B. Typ ) vorhanden ist, wie kann ich einen Map-by-Extracting-Key am besten erstellen ? val c: Collection[T] val m: Map[P, T] Ein Weg ist der folgende: m = new HashMap[P, T] c foreach { t => m add (t.getP, t) } Aber...
Wie kann man in Scala standardmäßig mit Datum und Uhrzeit arbeiten? Sollte ich Java-Typen wie java.util.Date verwenden oder gibt es native
Diese Frage passt derzeit nicht zu unserem Q & A-Format. Wir erwarten, dass die Antworten durch Fakten, Referenzen oder Fachwissen gestützt werden, aber diese Frage wird wahrscheinlich zu Debatten, Argumenten, Umfragen oder erweiterten Diskussionen führen. Wenn Sie der Meinung sind, dass diese...
Stimmt ... es wurde ziemlich viel diskutiert. Es gibt jedoch viele Unklarheiten und einige der Antworten ... einschließlich des Duplizierens von JAR-Referenzen in der JAR- / Executor- / Treiberkonfiguration oder in den Optionen. Die mehrdeutigen und / oder ausgelassenen Details Nach Unklarheiten...
class Person(val name:String,var age:Int ) def person = new Person("Kumar",12) person.age = 20 println(person.age) Diese Codezeilen werden ausgegeben 12, obwohl sie person.age=20erfolgreich ausgeführt wurden. Ich habe festgestellt, dass dies passiert, weil ich def in verwendet habe def person =...
Ich frage mich, ob es eine Möglichkeit gibt, asynchrone Aufrufe an eine Datenbank zu tätigen. Stellen Sie sich zum Beispiel vor, ich habe eine große Anfrage, deren Bearbeitung sehr lange dauert. Ich möchte die Anfrage senden und eine Benachrichtigung erhalten, wenn die Anfrage einen Wert...
Zum Lesen gibt es die nützliche Abstraktion Source. Wie kann ich Zeilen in eine Textdatei
In Java erfolgt das Lesen von Umgebungsvariablen mit System.getenv(). Gibt es eine Möglichkeit, dies in Scala zu
Ich bin neu zu spielen! Framework 2.1 (Java-Version) und haben keine Erfahrung mit Scala. Ich verstehe nicht, was in Build.scala ist und was bedeutet %und %%bedeutet. Ich googelte über sie, konnte aber ihre Bedeutung nicht finden. In meiner Build.scala-Datei habe ich: "org.hibernate" %...
Das Überladen von Operatoren in C ++ wird von vielen als A Bad Thing (tm) angesehen und als Fehler, der in neueren Sprachen nicht wiederholt werden darf. Sicherlich war es eine Funktion, die speziell beim Entwerfen von Java weggelassen wurde. Nachdem ich angefangen habe, Scala zu lesen, stelle ich...
Ich versuche, eine Funktion darzustellen, die keine Argumente akzeptiert und keinen Wert zurückgibt (ich simuliere die Funktion setTimeout in JavaScript, wenn Sie es wissen müssen.) case class Scheduled(time : Int, callback : => Unit) wird nicht kompiliert und sagt, dass "val" -Parameter...
Irgendwann stolpere ich in die halb mysteriöse Notation von def f[T](..) = new T[({type l[A]=SomeType[A,..]})#l] {..} in Scala-Blog-Posts, die eine Handwelle "Wir haben diesen Typ-Lambda-Trick verwendet" geben. Obwohl ich eine gewisse Intuition darüber habe (wir erhalten einen anonymen...
In Shapeless stellt der Nat-Typ eine Möglichkeit dar, natürliche Zahlen auf Typebene zu codieren. Dies wird beispielsweise für Listen mit fester Größe verwendet. Sie können sogar Berechnungen auf Typebene durchführen, z. B. eine Liste von NElementen an eine Liste von KElementen anhängen und eine...
Angenommen, ich mache so etwas wie: val df = sqlContext.load("com.databricks.spark.csv", Map("path" -> "cars.csv", "header" -> "true")) df.printSchema() root |-- year: string (nullable = true) |-- make: string (nullable = true) |-- model: string (nullable = true) |-- comment: string (nullable...