Suchergebnisse für Anfrage "scala"

5 die antwort

Wie können Sie aufhören, eine Option [Collection] zu erstellen, sobald Sie die erste None erreicht haben?

Beim Aufbau einer Sammlung in einemOptionWenn Sie versuchen, das nächste Mitglied der Sammlung zu erstellen, schlägt dies möglicherweise fehl, sodass die gesamte Sammlung ebenfalls fehlschlägt. Wenn ich zum ersten Mal kein Mitglied habe, möchte ...

1 die antwort

Wie akka tote Briefe anzeigen

Ich habe einen Schauspieler erstellt, der einige grundlegende Vorgänge ausführt und anscheinend ordnungsgemäß funktioniert. In meinen Protokollen wird jedoch regelmäßig Folgendes angezeigt [INFO] [05/28/2014 14:24:00.673] ...

3 die antwort

Spark atop of Docker akzeptiert keine Jobs

Ich versuche, ein Hallo-Welt-Beispiel mit spark + docker zu erstellen, und hier ist mein Code. object Generic { def main(args: Array[String]) { val sc = new SparkContext("spark://172.17.0.3:7077", "Generic", "/opt/spark-0.9.0") val NUM_SAMPLES = ...

TOP-Veröffentlichungen

1 die antwort

Apache Spark EOF-Ausnahme

Ich erhalte eine EOFException, wenn ein einfacher Job ausgeführt wird, der eine Textdatei liest und die Ergebnisse sammelt. Dies funktioniert gut auf meinem Entwicklungscomputer, schlägt jedoch fehl, wenn es im Standalone-Modus ausgeführt wird ...

1 die antwort

Ist die Verwendung von Try [Unit] der richtige Weg?

Ich bin kürzlich auf das Konzept von gestoßenTry/Success/Failure, und ich frage mich, wie man es für eine Methode verwendet, die den Rückgabetyp hatUnit. BenutztTry[Unit] der richtige weg? Vielleicht bin ich zu sehr von meinem Java-Hintergrund ...

1 die antwort

Wie verwende ich JSR-223, um den Scala-Interpreter in die sbt-Konsole zu bekommen?

In der sbt-Konsole kann ich die sbt-Version 0.13.5, die Scala-Version 2.11.1 bekommenjavax.script.ScriptEngine für Scala: scala> val engine = new javax.script.ScriptEngineManager().getEngineByName("scala") engine: javax.script.ScriptEngine = ...

1 die antwort

Kompilieren Sie Fehler beim Definieren eines Makros zum Konvertieren einer Instanz einer Fallklasse in eine Map und zurück

Ich versuche, den folgenden Blog-Beitrag zu verstehen, in dem erläutert wird, wie mithilfe von Makros ein generischer makrobasierter Ansatz zum Konvertieren von Fallklassenobjekten in und aus einer Karte erstellt ...

3 die antwort

Schreiben Sie in mehrere Ausgaben mit der Taste Scalding Hadoop, einem MapReduce-Job

Wie können Sie mit Scalding (/ cascading) in einem einzelnen Map Reduce-Job in mehrere Ausgaben schreiben, die vom Schlüssel abhängig sind? Das könnte ich natürlich gebrauchen.filter für alle möglichen Schlüssel, aber das ist ein schrecklicher ...

2 die antwort

Fehler beim Kompilieren der ScalaTest-Spezifikation

Ich bin neu in Scala und versuche es zu benutzenScalaTest [http://www.scalatest.org/]. Ich habe die Abhängigkeit in meine build.sbt-Datei als aufgenommenlibraryDependencies++=Seq( "org.scalatest" % "scalatest_2.11" % "2.1.7" % "test" ) und ...

1 die antwort

Wie bekomme ich die ClassOf eines ClassTags?

Das funktioniert nicht - kann ich meinen Code auf irgendeine Weise generieren lassen und irgendwie die Klasse eines ClassTags widerspiegeln? class Foo[T : reflect.ClassTag] { def foo = classOf[T] } <console>:7: error: class type required but T ...