Para comparar el rendimiento de Spark al usar Python y Scala, creé el mismo trabajo en ambos idiomas y comparé el tiempo de ejecución. Esperaba que ambos trabajos tomaran aproximadamente la misma cantidad de tiempo, pero el trabajo de Python solo tomó 27min, mientras que el trabajo de Scala tomó...
Muchos tipos de óptica tienen una representación de Van Laarhoven. Por ejemplo, un Lenstipo Lens s t a b puede representarse como: Functor f => (a -> f b) -> s -> f t Del mismo modo Traversal, a , se puede representar de manera similar, intercambiando la Functorrestricción por...
Aquí hay un fragmento de código de la documentación para fs2 . La función goes recursiva. La pregunta es ¿cómo sabemos si es seguro para la pila y cómo razonar si alguna función es segura para la pila? import fs2._ // import fs2._ def tk[F[_],O](n: Long): Pipe[F,O,O] = { def go(s: Stream[F,O],...
Estaba trabajando en los ejemplos de código del capítulo sobre Rasgos en la programación en Scala Edition1 https://www.artima.com/pins1ed/traits.html y me encontré con un comportamiento extraño debido a mi error tipográfico. Mientras se sobreescriben el método de un rasgo a continuación...
Estoy leyendo la programación del libro en scala, y se dice: ... en este caso, su efecto secundario es imprimir en la secuencia de salida estándar. y no veo dónde está el efecto secundario, ya que, para la misma entrada, println imprimirá la misma salida (creo) ACTUALIZAR, por ejemplo, cada...
Cuando se utiliza un entorno funcional como Scala y cats-effect, ¿se debe modelar la construcción de objetos con estado con un tipo de efecto? // not a value/case class class Service(s: name) def withoutEffect(name: String): Service = new Service(name) def withEffect[F: Sync](name: String):...
Tengo un marco de datos con el siguiente código: 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"))...
Tengo un servicio que transfiere mensajes a una velocidad bastante alta. Actualmente es atendido por akka-tcp y genera 3,5 millones de mensajes por minuto. Decidí probar grpc. Desafortunadamente, resultó en un rendimiento mucho menor: ~ 500k mensajes por minuto e incluso menos. ¿Podría...
¿Por qué la coincidencia de patrones funciona de manera diferente cuando el parámetro tipo proviene de un método de cierre en lugar de una clase de cierre? Por ejemplo, trait Base[T] case class Derived(v: Int) extends Base[Int] class Test[A] { def method(arg: Base[A]) = { arg match { case...
val i: java.lang.Integer = null val o: Option[Int] = Option(i) // This yields Some(0) ¿Cuál es la forma segura de convertir null: java.lang.Integera Scala
¿Cómo hago para que sbt incluya fuentes que no son de Java en artefactos publicados? Estoy usando el complemento Kotlin y no puedo entender cómo forzar a sbt a incluir el archivo .kt en el jar fuente publicado. Solo incluye archivos .java. Mucha gente en línea sugiere agregar el siguiente código...
Tengo un iterador de cadenas, donde cada cadena puede ser "H"(encabezado) o "D"(detalle). Quiero dividir este iterador en bloques, donde cada bloque comienza con un encabezado y puede tener de 0 a muchos detalles. Sé cómo resolver este problema cargando todo en la memoria. Por ejemplo, el...
Soy nuevo en Scala y quiero calcular una suma móvil con una ventana fija para una lista. Por ejemplo: dados los valores de la lista (1.0, 2.0, 3.0, 6.0, 7.0, 8.0, 12.0, 9.0, 4.0, 1.0), y el período 4, la función debería devolver: (1.0, 3.0, 6.0, 12.0, 18.0, 24.0, 33.0, 36.0, 33.0, 26.0) Si...