Tag: scala

scala> def foo[U](t: Any) = t.asInstanceOf[U] foo: [U](t: Any)U scala> val s: String = foo("hi") scala> val n = foo("hi") java.lang.ClassCastException: java.lang.String cannot be cast to scala.runtime.Nothing$ at .<init>(<console>:6) at .<clinit>(<console>) at RequestResult$.<init>(<console>:9) at RequestResult$.<clinit>(<console>) at RequestResult$scala_repl_result(<console>)

Zum Beispiel haben wir eine Parkett-Datei mit 2000 Lager-Symbole " Schlusskurs in den letzten 3 Jahren, und wir wollen berechnen, die 5-Tage gleitenden Durchschnitt für jedes symbol. Damit ich einen Funken zu erzeugen SQLContext und dann val

Habe ich einige Daten in HDFS /user/Cloudera/Test/*. Ich bin sehr gut in der Lage, um zu sehen, die Datensätze durch ausführen hdfs -dfs -cat Test/*. Nun die gleiche Datei, die ich brauche, es zu Lesen, als der

Folgende Ausnahme aufgetreten ist, wenn ein spark unit-test, der erfordert, snappy compression: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.java:317) at org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:219) at org.xerial.snappy.Snappy.<clinit>(Snappy.java:44) at org.apache.spark.io.SnappyCompressionCodec.<init>(CompressionCodec.scala:150) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)

Beim kompilieren des Maven-Projekt der folgende Fehler aufgetreten ist: [INFO] --- scala-maven-plugin:3.2.2:compile (scala-compile-first) @ spark-streaming-flume-sink_2.10 --- [WARNING] Zinc server is not available at port 3030 - reverting to normal incremental compile [INFO] Using incremental compilation [INFO] Compiling

Beim pattern-matching wird eine Ausnahme mit einer case-Anweisung, gibt es eine einfachere Methode für das matching der gleichen Ausnahme von eine Reihe von exception-Typen? Stattdessen: } catch { case e if e.isInstanceOf[MappingException] || e.isInstanceOf[ParseException] => Sowas wäre

Lesen dieses Artikels zu reduzieren, vs Falten in Scala http://josephmoniz.github.io/blog/2013/04/04/scala-reduce-vs-fold/ es heißt "Sie nehmen einen gewissen Wert von N und die Durchführung aggregation-Operationen, so dass das Endergebnis ist in der Regel einen Wert von <= N." Aber

Ich versuche, zu extrahieren Wörter aus einer Textdatei. Textdatei: "Line1 with words to extract" "Line2 with words to extract" "Line3 with words to extract" Folgendes gut funktioniert: val data = sc.textFile(file_in).map(_.toLowerCase).cache() val all = data.flatMap(a => "[a-zA-Z]+".r

Habe ich eine json-Datei wie unten. {"name":"method2","name1":"test","parameter1":"C:/Users/test/Desktop/Online.csv","parameter2": 1.0} Ich bin laden meine json-Datei. val sqlContext = new org.apache.spark.sql.SQLContext(sc) val df = sqlContext.read.json("C:/Users/test/Desktop/data.json") val df1=df.select($"name",$"parameter1",$"parameter2").toDF() df1.show() Ich habe 3 Funktion, wie unten: def method1(P1:String, P2:Double) { val data

Dies ist nur eine von diesen "ich Frage mich..." - Fragen. Scala hat unveränderliche Datenstrukturen und (optional) lazy vals etc. Wie nah kann ein Scala-Programm an, das voll rein (in die funktionale Programmierung Sinn) und voll faul

Habe ich DocsRDD : RDD[String, String] val DocsRDD = sc.wholeTextFiles("myDirectory/*" , 2) DocsRDD: Doc1.txt , bla bla bla .....\n bla bla bla \n bla ... bla Doc2.txt , bla bla bla .....bla \n bla bla \n bla

Wenn ich eine Klasse nimmt, dass ein Tupel in seinem Konstruktor unter anderem Werte wie: class Foo(a: Int, b: String, c: (Int, String)) Wie benutze ich einen abstrakten Typ zu geben, die Tupel einer mehr beschreibenden Namen

Habe ich eine json mit einige Felder und ich möchte, um zu überprüfen, ob einige von Ihnen anwesend ist. Ich bin extrahieren Sie den Wert und testen Sie es gegen JNothing, aber es ist viel zu ausführlich:

Wenn ich eine C-Klasse-definiert als class C[A] gibt es eine Möglichkeit zum erstellen einer neuen Instanz von A in C? So etwas wie class C[A] { def f(): A = new A() } Ich verstehe, dass, wenn

Scala 2.10 eingeführt Wert-Klassen. Sie sind sehr nützlich für das schreiben von typesafe-code. Zudem gibt es einige Einschränkungen, einige von Ihnen werden erkannt, durch die compiler, und einige erfordern Zuordnung in der runtime. Ich will Wert-Klassen mit

IntelliJ beschwert sich über diesen code: val document: Node //(initialized further up in the code) val s: String = (new scala.xml.PrettyPrinter(80, 4)).format(document)) Mit der Fehlermeldung: Cannot resolve Referenz-format mit einer solchen Signatur Jedoch - eine solche Funktion

Habe ich, um zu überprüfen, ob eine Tabelle existiert in den Bienenstock, mit Funken(1.6.2) scala Wenn es nicht ich habe zum erstellen einer leeren dataframe und speichern, die als eine hive-Tabelle. Wenn er vorhanden ist, überschreiben Sie

Arbeite ich mit einigen einfachen Daten-Strukturen und-Sammlungen im Scala und ich habe gemerkt, was ich denke ist merkwürdig Verhalten. Hier ist das Objekt: class State (protected val trackmap: Map[Int, List[String]]) { override def clone : State =

Habe ich ein Spiel-Projekt. Leider bin ich zu Deserialisieren einige Klassen, die serialisiert wurden mit scala 2.9.2. Da spielen verwendet 2.9.1 es ist eine InvalidClassException. Caused by: java.io.InvalidClassException: scala.Option; local class incompatible: stream classdesc serialVersionUID = 2832403187243187948,

Ich versuche, mit meinem Scala-Akka-Anwendung mit meiner MySQL-Datenbank auf zwei separaten Docker-Containern. Ich fand heraus, dass Docker ermöglicht es Entwicklern, um die Verbindung Ihrer Anwendung auf Ihre Datenbanken mit der Flagge namens-link. In meinem Dockerfiles, in denen

Ich bin liebäugelt mit Specs2 und ScalaTest für BDD in Scala. Ich habe geschrieben, die Erwartungen Specs2, wenn ich zu behaupten, dass eine bestimmte Ausnahme sollte nicht geworfen werden. "do something" in { { .... } must

Ich hava ein DataFrame,das DataFrame hava zwei Spalte 'value' und 'timestamp', die 'timestmp' ist bestellt,ich möchte die Letzte Zeile des DataFrame,was soll ich tun? dies ist mein input: +-----+---------+ |value|timestamp| +-----+---------+ | 1| 1| | 4| 2|

Ich habe schwer gemacht Einsatz von case-Klassen in meinem code, Antworten auf die zugrunde liegenden Definitionen von Gleichheit Fall Klasse, richtig zu Verhalten. Dann jetzt fand ich, dass ich hinzufügen müssen, um ein weiteres Feld, Mitglied zu

In der Scala-Anwendung, versuche zu Lesen von Zeilen aus einer Datei, die mit java nio try-with-resource-Konstrukt. Scala-version 2.11.8 Java version 1.8 try(Stream<String> stream = Files.lines(Paths.get("somefile.txt"))){ stream.forEach(System.out::println); //will do business process here }catch (IOException e) { e.printStackTrace(); //will

Wissen Sie etwas über Möglichkeiten der aufrufen der Scala von R und mit R (Bibliotheken) in Scala? Beste Grüße Raffael Hallo, Alle Zusammen. Ein Weg, vielleicht nicht speziell für diese situation wäre die Verwendung eines Restful-service. Aber