Suchergebnisse für Anfrage "scala"
Wie konvertiere ich Scala Map in JSON String?
Zum Beispiel habe ich diesen Map-Wert in Scala: val m = Map( "name" -> "john doe", "age" -> 18, "hasChild" -> true, "childs" -> List( Map("name" -> "dorothy", "age" -> 5, "hasChild" -> false), Map("name" -> "bill", "age" -> 8, "hasChild" -> ...
Handling verdoppelt sich in ScalaTest
Ich habe gerade angefangen, ScalaTest zu verwenden, und ich verwende Folgendes, um zwei Doubles in meiner Spezifikation wie folgt zu vergleichen: it should "calculate the price" in { val x = new X(10,10,12,1000) assert(x.price() === 185.92) ...
Funktionen ohne Argumente, mit Einheit als Argument in scala
def foo(x:Int, f:Unit=>Int) = println(f()) foo(2, {Unit => 3+4} //case1 def loop:Int = 7 foo(2, loop) //does not compile changing loop to //case 2 def loop():Int = 7 foo(2, loop) // does not compile changing loop to //case 3 def loop(x:Unit): ...
Spark Streaming: StreamingContext liest keine Datendateien
Ich bin neu in Spark Streaming und versuche, mit Spark-Shell damit zu beginnen. Angenommen, ich habe ein Verzeichnis namens "dataTest" im Stammverzeichnis von spark-1.2.0-bin-hadoop2.4. Der einfache Code, den ich in der Shell testen möchte, ...
scala sbt assembly "kein Hauptmanifestattribut"
Ich verwende das Assembly-Plugin in sbt, um mein Projekt zusammenzustellen. Aber Fehler treten auf, wenn sie von "java -jar xx.jar" - @ ausgeführt werde "kein Hauptmanifestattribut". Ich denke, es ist, weil es zwei Dateien in meinem @ ...
Redis on Spark: Task nicht serialisierbar
Wir verwenden Redis on Spark, um unsere Schlüssel-Wert-Paare zwischenzuspeichern. Dies ist der Code: import com.redis.RedisClient val r = new RedisClient("192.168.1.101", 6379) val perhit = perhitFile.map(x => { val arr = x.split(" ") val readId ...
Wie teste ich Methoden, die Future zurückgeben?
Ich möchte eine Methode testen, die ein @ zurückgiFuture. Meine Versuche waren wie folgt: import org.specs2.mutable.Specification import scala.concurrent.ExecutionContext.Implicits.global import scala.util.{Failure, Success} class ...
Wie verwende ich Reactive Streams für die NIO-Binärverarbeitung?
Gibt es einige Codebeispiele für die Verwendung von org.reactivestreams [http://www.reactive-streams.org/] Bibliotheken zur Verarbeitung großer Datenströme mit Java NIO (für hohe Leistung)? Ich strebe eine verteilte Verarbeitung an, daher sind ...
Dateien rekursiv aus Unterverzeichnissen mit Funken aus s3 oder lokalem Dateisystem lesen
Ich versuche, Dateien aus einem Verzeichnis zu lesen, das viele Unterverzeichnisse enthält. Die Daten sind in S3 und ich versuche dies zu tun: val rdd ...
Warum führen Scala 2.11 und Spark mit Jakobsmuschel zu "java.lang.NoSuchMethodError: scala.reflect.api.JavaUniverse.runtimeMirror"?
Ich verwende Scala 2.11, Spark und Scallop https: //github.com/scallop/scallo [https://github.com/scallop/scallop]). Ich habe sbt verwendet, um eine Anwendung zu erstellen, in der es keine Abhängigkeiten für Spark ...