Suchergebnisse für Anfrage "scala"
Real Life Beispiele für Scala Infix-Typen
Ich habe ein interessantes Syntax-Zeug gefunden. Es heißtInfix type. Beispiel class M[T, U] new (Int M String)Und jetzt suche ich nach Beispielen dieses Typs aus einigen gängigen Frameworks oder Bibliotheken. Wo finde ich sie? Irgendwelche ...
Wie füge ich ein benutzerdefiniertes Verzeichnis zum Scala SBT-Projekt hinzu?
Wir habenconf Verzeichnis in unserem Projekt, das in Ordnung ist, aber eine der neuen Komponenten erfordert eine eigene Konfiguration in @ platziert werdconfig Verzeichnis und wir können diese Anforderung nicht ändern. In meiner build.scala habe ...
Spark JoinWithCassandraTable auf dem TimeStamp-Partitionsschlüssel STUCK
Ich versuche, einen kleinen Teil einer großen C * -Tabelle zu filtern, indem ich Folgendes verwende: val snapshotsFiltered = sc.parallelize(startDate ...
Validierungen in Wertklassen
SIP-15 bedeutet, dass Wertklassen verwendet werden können, um beispielsweise neue numerische Klassen wie positive Zahlen zu definieren. Ist es möglich, eine solche Einschränkung so zu codieren, dass der zugrunde liegende Wert> 0 ist, wenn kein ...
Spark Abschlussargument bindend
ch arbeite mit Apache Spark in Scal Ich habe ein Problem beim Versuch, eine RDD mit Daten von einer zweiten RDD zu manipulieren. Ich versuche, die 2. RDD als Argument für eine Funktion zu übergeben, die gegen die erste RDD 'abgebildet' wird, ...
Spark UDF mit varargs
Ist es eine einzige Option, alle Argumente bis zu 22 aufzulisten, wie in der Dokumentation ...
Nullwerte in Spark DataFrame ersetzen
Ich habe hier eine Lösung gesehen, aber als ich es ausprobiert habe, funktioniert es bei mir nicht. Zunächst importiere ich eine cars.csv-Datei: val df = sqlContext.read .format("com.databricks.spark.csv") .option("header", "true") ...
Scalacheck Case Class Zufallsdatengenerator
Ich versuche mit Scalacheck zufällige Daten zu generieren. Ich habe eine Hierarchie von Fallklassen mit vielen Eigenschaften. Bisher habe ich nur die folgende Möglichkeit gefunden, die Fallklassen zu füllen: case class Data(a: String, b: ...
Wie kann ich eine Broadcast-Variable im Spark-Streaming aktualisieren?
Ich habe, glaube ich, einen relativ häufigen Anwendungsfall für Funken-Streaming: Ich habe einen Strom von Objekten, die ich basierend auf einigen Referenzdaten filtern möchte Initial dachte ich, dass dies eine sehr einfache Sache wäre, mit ...
So testen Sie die privaten Methoden eines Objekts in Scala
Ich habe ein Beispielobjekt: object Foo { private def sayFoo = "Foo!" }Und ich möchte die private sayFoo-Methode ohne die folgenden Problemumgehungen testen: 1. Ohne sie als package private zu definieren. 2. Ohne sie als protected zu definieren ...