J'ai écrit du code Scala pour effectuer une opération élément par élément sur une collection. Ici, j'ai défini deux méthodes qui effectuent la même tâche. Une méthode utilise zipet l'autre utilise zipped. def ES (arr :Array[Double], arr1 :Array[Double]) :Array[Double] = arr.zip(arr1).map(x =>...
Pour comparer les performances de Spark lors de l'utilisation de Python et Scala, j'ai créé le même travail dans les deux langues et comparé le runtime. Je m'attendais à ce que les deux travaux prennent à peu près la même quantité de temps, mais le travail Python a pris seulement 27min, tandis que...
De nombreux types d'optiques ont une représentation van Laarhoven. Par exemple, un Lenstype Lens s t a b peut être représenté comme: Functor f => (a -> f b) -> s -> f t De même, a Traversal, peut être représenté de manière similaire, en échangeant la Functorcontrainte pour Applicative:...
Voici un morceau de code de la documentation de fs2 . La fonction goest récursive. La question est de savoir comment savoir si elle est sans danger pour la pile et comment raisonner si une fonction est sans danger pour la pile? import fs2._ // import fs2._ def tk[F[_],O](n: Long): Pipe[F,O,O] = {...
Je travaillais sur les exemples de code du chapitre Traits in Programming in Scala Edition1 https://www.artima.com/pins1ed/traits.html et est tombé sur un comportement étrange à cause de ma faute de frappe. Bien que la méthode de remplacement d'un trait sous l'extrait de code ne donne aucune erreur...
Je lis la programmation du livre en scala, et il est dit: ... dans ce cas, son effet secondaire est l'impression sur le flux de sortie standard. et je ne vois pas où est l'effet secondaire, car, pour la même entrée, println imprimera la même sortie (je pense) UPDATE par exemple chaque fois que nous...
Lorsque vous utilisez un environnement fonctionnel comme Scala et cats-effect, la construction d'objets avec état doit-elle être modélisée avec un type d'effet? // not a value/case class class Service(s: name) def withoutEffect(name: String): Service = new Service(name) def withEffect[F:...
J'ai une trame de données avec le code suivant: def test(lat: Double, lon: Double) = { println(s"testing ${lat / lon}") Map("one" -> "one", "two" -> "two") } val testUDF = udf(test _) df.withColumn("test", testUDF(col("lat"), col("lon"))) .withColumn("test1", col("test.one"))...
J'ai un service qui transfère des messages à un taux assez élevé. Actuellement, il est desservi par akka-tcp et génère 3,5 millions de messages par minute. J'ai décidé d'essayer grpc. Malheureusement, cela a entraîné un débit beaucoup plus faible: ~ 500 000 messages par minute, encore moins....
Pourquoi la correspondance de modèles fonctionne-t-elle différemment lorsque le paramètre de type provient d'une méthode englobante par opposition à une classe englobante? Par exemple, trait Base[T] case class Derived(v: Int) extends Base[Int] class Test[A] { def method(arg: Base[A]) = { arg match...
val i: java.lang.Integer = null val o: Option[Int] = Option(i) // This yields Some(0) Quel est le moyen sûr de se convertir null: java.lang.Integerà Scala