Suchergebnisse für Anfrage "scala"
Scala in einen Variablentyp umgewandelt
Ich habe den folgenden Code zum Besetzen vonWer zum Typ vonStandar: def fct[T](value: Any, default: T): T = { val result = value.asInstanceOf[T] println(result, result.getClass.getName, result.isInstanceOf[T]) result } val res = fct("foo", ...
Datenrahmen nach Wert filtern, der NICHT in der Spalte eines anderen Datenrahmens vorhanden ist [duplizieren]
Diese Frage hat hier bereits eine Antwort: Filter Spark DataFrame basierend auf einem anderen DataFrame, der Blacklist-Kriterien angibt [/questions/39887526/filter-spark-dataframe-based-on-another-dataframe-that-specifies-blacklist-crite] 2 ...
Erklären Sie diesen Mustervergleichscode
Dieser Code stammt vonÜberprüfen eines Datensatzes mit Scala's Pattern Matching [http://notes.langdale.com.au/Querying_a_Dataset_with_Scala_s_Pattern_Matching.html] : object & { def unapply[A](a: A) = Some((a, a)) } "Julie" match { ...
Mit Spark-Datenrahmen auf dem Schlüssel verbinden
Ich habe zwei Datenrahmen erstellt. Wie können wir mehrere Spark-Datenrahmen verbinden? Zum Beispiel PersonDf, ProfileDf mit einer gemeinsamen Spalte alspersonId as (Schlüssel). Wie können wir nun einen Dataframe haben, der @ kombinierPersonDf ...
Ausführung des Shell-Skripts aus der Scala-Anwendung
Ich möchte das @ ausführsh -Datei aus der Scala-Anwendung. Angenommen, ich habecreatePassword.sh Datei und ich muss diese aufrufensh Datei aus der Scala-Anwendung und erhalte die Ausgabe zurück. Wie kann ich mit der Scala-Anwendung etwas erreichen?
SBT kann beim Versuch, von einem virtuellen Artifactory-Repository herunterzuladen, keine Anmeldeinformationen finden
Ich versuche, SBT hinter einer Unternehmensfirewall auszuführen. Ein anderes Team hat einen Artifactory-Proxy konfiguriert. Dieser Proxy funktioniert einwandfrei, wenn der anonyme Zugriff aktiviert ist. Wenn wir jedoch ein Kennwort festlegen, ...
NLineInputFormat funktioniert nicht in Spark
Was ich möchte, ist im Grunde, dass jedes Datenelement aus 10 Zeilen besteht. Mit dem folgenden Code besteht jedes Element jedoch noch aus einer Zeile. Welchen Fehler mache ich hier? val conf = new SparkConf().setAppName("MyApp") ...
Spark UDF hat mehr als einmal pro Datensatz aufgerufen, wenn DF zu viele Spalten hat
Ich verwende Spark 1.6.1 und stoße auf ein merkwürdiges Verhalten: Ich führe eine UDF mit einigen umfangreichen Berechnungen (eine Physiksimulation) für einen Datenrahmen aus, der einige Eingabedaten enthält, und erstelle ...
Allgemeine 'Map'-Funktion für Scala-Tupel?
Ich möchte die Elemente eines Scala-Tupels (oder Triple, ...) mit einer einzigen Funktion abbilden, die Typ R zurückgibt. Das Ergebnis sollte ein Tupel (oder Triple, ...) mit Elementen des Typs R sein. OK, wenn die Elemente des Tupels vom selben ...
Wie verwende ich Akka-HTTP-Client-Websocket? Nachricht senden
Ich versuche es mit clientseitigem Websocket, indem ich doc unter @ folg webSocketClientFlow [http://doc.akka.io/docs/akka/2.4/scala/http/client-side/websocket-support.html#webSocketClientFlow] . sample code is: import akka.actor.ActorSystem ...