Suchergebnisse für Anfrage "scala"
Werden rekursive Strukturtypen in Scala nicht mehr unterstützt?
Einige Leute behaupten, dass scala mit rekursiven Strukturtypen umgehen kann, wenn Sie die Option -Yrecursion von scalac verwenden. Trotzdem kompiliert mein minimalistisches Beispiel nicht: type Num = { def +(n: Num): Num }Compilation ergibt: $ ...
Wie debuggen Sie Typelevel-Code?
In den meisten Fällen wird nur ein impliziter, nicht gefundener Fehler angezeigt. Sie wissen nicht, wo in der Kette der impliziten Konstruktion dies fehlgeschlagen ist. Anscheinend können Sie Runtime-Debug- oder Print-Anweisungen nicht ...
Wie konvertiere ich einen JSON-String in ein BSONDocument
Ich habe die folgende Funktion, die den ReactiveMongo-Treiber verwendet und tatsächlich gute Arbeit beim Schreiben in die Datenbank leistet. def writeDocument() = { val document = BSONDocument( "firstName" -> "Stephane", "lastName" -> ...
Scodec-Kombinatoren: Der Header enthält eine magische Zahl, die zur Unterscheidung von @ -Typen verwendet wir
Ich suche nach einer Möglichkeit, ein Protokoll wie das folgende zu nähern: case class Request(bodyType: Int, foo: Int, bar: Int, body: RequestBody) sealed trait RequestBody case class Read(key: String) extends RequestBody case class Write(key: ...
Einfügung-geordnetes ListSet
ListSet (collection.immutable.ListSet) ist eine umgekehrt geordnete Menge. Ich brauche bestelltes Set. Dies ist ein Beispiel für das ursprüngliche ListSet: var a = ListSet(1,2,3) var ite = a.iterator ite.next // returns 3 ite.next // returns 2 ...
Zuverlässigkeitsprobleme mit Checkpointing / WAL in Spark Streaming 1.6.0
Beschreibun Wir haben eine Spark Streaming 1.5.2-Anwendung in Scala, die JSON-Ereignisse aus einem Kinesis Stream liest, einige Transformationen / Aggregationen durchführt und die Ergebnisse in verschiedene S3-Präfixe schreibt. Das aktuelle ...
shapeless HList to TupleN, wobei die Tupelform nicht genau mit der HList-Form übereinstimmen muss
Ich möchte das Äquivalent erstellen zu: def toTupleN[A1, ..., AN, L <: HList](l: L): TupleN[A1, ..., AN]Code usingtoTupleN sollte nur kompilieren, wenn es genau ein @ giN Kombination von Werten inl dass das Tupel aus erstellt werden konnte. ...
Spark 1.6: java.lang.IllegalArgumentException: spark.sql.execution.id ist bereits gesetzt
Ich verwende spark 1.6 und stoße auf das obige Problem, wenn ich den folgenden Code ausführe: // Imports import org.apache.spark.sql.hive.HiveContext import org.apache.spark.{SparkConf, SparkContext} import org.apache.spark.sql.SaveMode import ...
Spark Dataframes UPSERT an Postgres-Tabelle
Ich verwende Apache Spark DataFrames, um zwei Datenquellen zu verbinden und das Ergebnis als anderen DataFrame abzurufen. Ich möchte das Ergebnis in eine andere Postgres-Tabelle schreiben. Ich sehe diese Option: myDataFrame.write.jdbc(url, ...
Scala unveränderliche Objekte und Eigenschaften mit Val-Feldern
Ich möchte mein Domain-Modell nur mit unveränderlichen Objekten erstellen. Ich möchte aber auch Merkmale mit Val-Feldern verwenden und einige Funktionen auf Merkmale übertragen. Bitte schauen Sie sich folgendes Beispiel an: trait Versionable { ...